added cloud tasks queue for refresh materialized view

Author: qcdyx

infra/functions-python/main.tf

@@ -968,7 +968,6 @@ resource "google_cloudfunctions2_function" "reverse_geolocation_populate" {
     environment_variables = {
       PYTHONNODEBUGRANGES = 0
       DB_REUSE_SESSION = "True"
-      GOOGLE_FUNCTION_SOURCE = "src/main.py"
     }
     available_memory = local.function_reverse_geolocation_populate_config.available_memory
     timeout_seconds = local.function_reverse_geolocation_populate_config.timeout
@@ -1243,7 +1242,6 @@ resource "google_cloudfunctions2_function" "tasks_executor" {
       PROJECT_ID  = var.project_id
       ENV = var.environment
       PUBSUB_TOPIC_NAME = "rebuild-bounding-boxes-topic"
-      GOOGLE_FUNCTION_SOURCE = "src/main.py"
     }
     available_memory                 = local.function_tasks_executor_config.memory
     timeout_seconds                  = local.function_tasks_executor_config.timeout
@@ -1421,6 +1419,26 @@ resource "google_cloud_tasks_queue" "update_validation_report_task_queue" {
   }
 }
 
+# Task queue to invoke refresh_materialized_view function
+resource "google_cloud_tasks_queue" "refresh_materialized_view_task_queue" {
+  project  = var.project_id
+  location = var.gcp_region
+  name     = "refresh-materialized-view-task-queue"
+
+  rate_limits {
+    max_concurrent_dispatches = 2
+    max_dispatches_per_second = 0.5
+  }
+
+  retry_config {
+    # This will make the cloud task retry for ~30 minutes
+    max_attempts  = 31
+    min_backoff   = "120s"
+    max_backoff   = "120s"
+    max_doublings = 2
+  }
+}
+
 # Task queue to invoke gbfs_validator_batch function for the scheduler
 resource "google_cloudfunctions2_function_iam_member" "gbfs_validator_batch_invoker" {
   project        = var.project_id