check_new_csvs_subdag in branchpythonop

lsst-uk · Jul 3, 2024 · d2ad961 · d2ad961
1 parent 59e48a8
commit d2ad961
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/echo-side/dags/monitor.py b/echo-side/dags/monitor.py
@@ -95,7 +95,7 @@ def list_new_csvs(file_path):
 
 conditional_op = BranchPythonOperator(
     task_id='conditional_op',
-    python_callable=lambda: 'check_new_csvs_op' if len(new_csvs) > 0 else 'end',
+    python_callable=lambda: 'check_new_csvs_subdag' if len(new_csvs) > 0 else 'end',
     dag=dag,
 )