fix: var name

cka-y · cka-y · commit bb321ee95bda · 2025-10-20T12:43:55.000-04:00
diff --git a/functions-python/tasks_executor/src/tasks/data_import/data_import_utils.py b/functions-python/tasks_executor/src/tasks/data_import/data_import_utils.py
@@ -5,7 +5,7 @@
 from google.cloud import pubsub_v1
 
 PROJECT_ID = os.getenv("PROJECT_ID")
-DATASET_BATCH_TOPIC = os.getenv("DATASET_BATCH_TOPIC_NAME")
+DATASET_BATCH_TOPIC = os.getenv("DATASET_PROCESSING_TOPIC_NAME")
 
 
 def trigger_dataset_download(
