Added update/removal checking for empty dirs

cedadev · Feb 6, 2024 · 17afea1 · 17afea1
1 parent b18ca04
commit 17afea1
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/pipeline/compute/serial_process.py b/pipeline/compute/serial_process.py
@@ -118,9 +118,17 @@ def __init__(self,
             self.proj_dir = f'{self.workdir}/in_progress/{self.proj_code}'
 
         if 'update' in cfg:
-            self.updates = cfg['update']
+            try:
+                self.updates = dict(cfg['update'])
+            except ValueError:
+                logger.warning('Updates attribute not read')
+                self.updates = {}
         if 'remove' in cfg:
-            self.removals = cfg['remove']
+            try:
+                self.removals = dict(cfg['remove'])
+            except ValueError:
+                logger.warning('Removal attribute not read')
+                self.removals = {}
 
         if 'type' in detail:
             self.use_json = (detail['type'] == 'JSON')