From 43de0a2bea26fe110e90195529fdce2f858ce712 Mon Sep 17 00:00:00 2001 From: Dave McKay Date: Wed, 3 Jul 2024 11:50:56 +0100 Subject: [PATCH] . --- echo-side/dags/monitor.py | 1 + 1 file changed, 1 insertion(+) diff --git a/echo-side/dags/monitor.py b/echo-side/dags/monitor.py index b075f68..4901a61 100644 --- a/echo-side/dags/monitor.py +++ b/echo-side/dags/monitor.py @@ -97,6 +97,7 @@ def check_new_csvs(csv): volume_mounts=[logs_volume_mount], get_logs=True, ) + check_new_csvs_op # Set the task sequence list_csv_files >> compare_csv_file_lists >> list_new_csvs