diff --git a/echo-side/dags/monitor.py b/echo-side/dags/monitor.py index 1075319..ead6611 100644 --- a/echo-side/dags/monitor.py +++ b/echo-side/dags/monitor.py @@ -131,5 +131,6 @@ def check_new_csvs(new_csvs): )] # Set the task sequence -list_csv_files >> compare_csv_file_lists >> list_new_csvs_op >> conditional_op >> [check_new_csvs_op,end] >> check_csvs +list_csv_files >> compare_csv_file_lists >> list_new_csvs_op >> conditional_op >> [check_new_csvs_op,end] +check_new_csvs_op >> check_csvs \ No newline at end of file