From 16e139e75f1364685242147bc50332834ad2b3c0 Mon Sep 17 00:00:00 2001 From: Hadrien Bossard Date: Tue, 31 Dec 2024 12:43:31 +0100 Subject: [PATCH] bug(colter): fix Dataset outlets --- workflows/data_pipelines/colter/colter_dag.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/workflows/data_pipelines/colter/colter_dag.py b/workflows/data_pipelines/colter/colter_dag.py index d5418d6b..a212d252 100644 --- a/workflows/data_pipelines/colter/colter_dag.py +++ b/workflows/data_pipelines/colter/colter_dag.py @@ -58,8 +58,8 @@ def save_date_last_modified(): def send_file_to_minio(): return colter_processor.send_file_to_minio() - @task - def compare_files_minio(outlets=[dataset_colter]): + @task(outlets=[dataset_colter]) + def compare_files_minio(): return colter_processor.compare_files_minio() (