diff --git a/csd3-side/scripts/lsst-backup.py b/csd3-side/scripts/lsst-backup.py
index 3919dec..a8e6093 100644
--- a/csd3-side/scripts/lsst-backup.py
+++ b/csd3-side/scripts/lsst-backup.py
@@ -1381,14 +1381,15 @@ def process_files(s3, bucket_name, api, current_objects, exclude, local_dir, des
                 processing_start,
                 mem_per_worker,
             ))
-        for ulf in as_completed(upload_futures):
-            if 'exception' in ulf.status or 'error' in ulf.status:
-                f_tuple = ulf.exception(), ulf.traceback()
-                failed.append(f_tuple)
-                upload_futures.remove(ulf)
-            else:
-                upload_futures.remove(ulf)
-                to_collate.loc[to_collate['id'] == id, 'upload'] = False
+
+    for ulf in as_completed(upload_futures):
+        if 'exception' in ulf.status or 'error' in ulf.status:
+            f_tuple = ulf.exception(), ulf.traceback()
+            failed.append(f_tuple)
+            upload_futures.remove(ulf)
+        else:
+            upload_futures.remove(ulf)
+            to_collate.loc[to_collate['id'] == id, 'upload'] = False
 
 
 
@@ -1840,14 +1841,14 @@ def error(self, message):
             elif api == 'swift':
                 process_files(s3, bucket_name, api, current_objects, exclude, local_dir, destination_dir, dryrun, log, global_collate, use_compression, client, mem_per_worker, collate_list_file, save_collate_list, file_count_stop)
 
-        def get_all_tasks(dask_scheduler=None):
-            return dask_scheduler.tasks
+        # def get_all_tasks(dask_scheduler=None):
+        #     return dask_scheduler.tasks
 
-        stream = client.run_on_scheduler(get_all_tasks)
-        print(stream)
-        if len(stream) > 0:
-            print('Waiting for tasks to complete.')
-            client.wait(stream)
+        # stream = client.run_on_scheduler(get_all_tasks)
+        # print(stream)
+        # if len(stream) > 0:
+        #     print('Waiting for tasks to complete.')
+        #     client.wait(stream)
         # success = True
     # except Exception as e:
     #     print(e)