diff --git a/services/shared/storage.py b/services/shared/storage.py index c7b27ff..69567a6 100644 --- a/services/shared/storage.py +++ b/services/shared/storage.py @@ -221,8 +221,9 @@ def upload_normalized_text( Stores under parsed/{ticker}/{yyyy}/{mm}/{dd}/{document_id}/normalized.txt """ ts = timestamp or datetime.now(timezone.utc) + safe_ticker = ticker or "_global" path = ( - f"parsed/{ticker}/{ts.year}/{ts.month:02d}/{ts.day:02d}/" + f"parsed/{safe_ticker}/{ts.year}/{ts.month:02d}/{ts.day:02d}/" f"{document_id}/normalized.txt" ) return upload_artifact( @@ -244,8 +245,9 @@ def upload_parser_output( Stores under parsed/{ticker}/{yyyy}/{mm}/{dd}/{document_id}/parser_output.json """ ts = timestamp or datetime.now(timezone.utc) + safe_ticker = ticker or "_global" path = ( - f"parsed/{ticker}/{ts.year}/{ts.month:02d}/{ts.day:02d}/" + f"parsed/{safe_ticker}/{ts.year}/{ts.month:02d}/{ts.day:02d}/" f"{document_id}/parser_output.json" ) return upload_artifact(