.

lsst-uk · Aug 16, 2024 · 9dacca0 · 9dacca0
1 parent 6d7b6b7
commit 9dacca0
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/echo-side/dags/monitor.py b/echo-side/dags/monitor.py
@@ -98,7 +98,9 @@ def get_new_csvs(bucket_name):
 
     check_uploads = []
 
-    def check_uploads(bucket_name, new_csvs_list):    
+    for bucket_new_csvs in new_csvs.items():
+        bucket_name = bucket_new_csvs[0]
+        new_csvs_list = bucket_new_csvs[1]
         for csv in new_csvs_list:
             check_uploads.append(
                 KubernetesPodOperator(