fix: logging and requirement errors

adswerve · Feb 16, 2024 · 1a029ee · 1a029ee
1 parent 9a7357e
commit 1a029ee
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/cf/requirements.txt b/cf/requirements.txt
@@ -4,4 +4,5 @@ google-cloud-bigquery~=3.13.0
 google-cloud-pubsub~=2.2.0
 google-cloud-bigquery-storage~=2.10.1
 pytz~=2022.7.1
-db_dtypes~=1.1.1
+db_dtypes~=1.1.1
+flask<3.0,>=1.0
diff --git a/cfintraday/main.py b/cfintraday/main.py
@@ -186,12 +186,11 @@ def manage_intraday_schedule(event, context="context"):
                 # Construct the request body.
                 cron_schedule = input_event.intraday_schedule()
 
-                MESSAGE_DATA = {"protoPayload": {
-                    "serviceData": {"jobCompletedEvent": {"job": {"jobConfiguration": {"load": {"destinationTable": {
-                        "datasetId": input_event.dataset
-                        , "projectId": input_event.gcp_project
-                        , "tableId": f"events_intraday_{input_event.table_date_shard}"
-                    }}}}}}}}
+                MESSAGE_DATA = {
+                    "protoPayload": {
+                        "resourceName": f"projects/{input_event.gcp_project}/datasets/{input_event.dataset}/tables/events_intraday_{input_event.table_date_shard}"
+                    }
+                }
 
                 topic_name = os.environ["TOPIC_NAME"]