add missing task name in call

Author: davidgamez

api/src/shared/common/gcp_utils.py

@@ -1,8 +1,13 @@
+import json
 import logging
 import os
 from google.cloud import tasks_v2
 from google.protobuf.timestamp_pb2 import Timestamp
 
+REFRESH_VIEW_TASK_EXECUTOR_BODY = json.dumps(
+    {"task": "refresh_materialized_view", "payload": {"dry_run": False}}
+).encode()
+
 
 def create_refresh_materialized_view_task():
     """
@@ -40,19 +45,18 @@ def create_refresh_materialized_view_task():
         gcp_region = os.getenv("GCP_REGION")
         environment_name = os.getenv("ENVIRONMENT")
         url = f"https://{gcp_region}-" f"{project}.cloudfunctions.net/" f"tasks_executor-{environment_name}"
-
         # Enqueue the task
         try:
             create_http_task_with_name(
                 client=tasks_v2.CloudTasksClient(),
-                body=b"",
+                body=REFRESH_VIEW_TASK_EXECUTOR_BODY,
                 url=url,
                 project_id=project,
                 gcp_region=gcp_region,
                 queue_name=queue,
                 task_name=task_name,
                 task_time=proto_time,
-                http_method=tasks_v2.HttpMethod.GET,
+                http_method=tasks_v2.HttpMethod.POST,
             )
             logging.info("Scheduled refresh materialized view task for %s", task_name)
             return {"message": "Refresh task for %s scheduled." % task_name}, 200