Fix callable

NASA-IMPACT · Dec 3, 2024 · 0e5cc7c · 0e5cc7c
1 parent 3a48975
commit 0e5cc7c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dags/veda_data_pipeline/veda_dataset_pipeline.py b/dags/veda_data_pipeline/veda_dataset_pipeline.py
@@ -106,7 +106,7 @@ def mutate_payload(**kwargs):
 
     collection_grp = collection_task_group()
     mutate_payload_task = mutate_payload()
-    discover = discover_from_s3_task.partial(alt_payload=mutate_payload_task()).expand(event=extract_discovery_items())
+    discover = discover_from_s3_task.partial(alt_payload=mutate_payload_task).expand(event=extract_discovery_items())
     discover.set_upstream(collection_grp)  # do not discover until collection exists
     get_files = get_dataset_files_to_process(payload=discover)