diff --git a/echo-side/dags/monitor.py b/echo-side/dags/monitor.py index a6a8b022..e56eaee7 100644 --- a/echo-side/dags/monitor.py +++ b/echo-side/dags/monitor.py @@ -105,5 +105,8 @@ def get_new_csvs(bucket_name): ) # Set the task sequence - list_csv_files >> compare_csv_file_lists >> get_new_csvs_task >> check_uploads + list_csv_files + compare_csv_file_lists + get_new_csvs_task + check_uploads \ No newline at end of file