From 0e5cc7c4a29bb403c7a9da16f054168c9d814568 Mon Sep 17 00:00:00 2001 From: ividito Date: Tue, 3 Dec 2024 11:39:34 -0400 Subject: [PATCH] Fix callable --- dags/veda_data_pipeline/veda_dataset_pipeline.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dags/veda_data_pipeline/veda_dataset_pipeline.py b/dags/veda_data_pipeline/veda_dataset_pipeline.py index 2980bfe..c735697 100644 --- 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)