do not add empty command chains into the queue

mara · May 19, 2022 · 7bde9b5 · 7bde9b5
1 parent f7c0d40
commit 7bde9b5
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/mara_pipelines/execution.py b/mara_pipelines/execution.py
@@ -503,6 +503,9 @@ def run(self):
         succeeded = True
         try:
             for commands in self.task.feed_workers():
+                if not commands:
+                    # skip empty command chains
+                    continue
                 self._command_queue_put(commands)
         except Exception as e:
             logger.log(message=traceback.format_exc(), format=logger.Format.VERBATIM, is_error=True)