From d70b1ab13bfca940cd257c37f3e06356470af498 Mon Sep 17 00:00:00 2001 From: Francesco Di Natale Date: Wed, 7 Jul 2021 19:36:53 -0700 Subject: [PATCH] Addition of clean up when detecting a cancel. --- maestrowf/datastructures/core/executiongraph.py | 1 + 1 file changed, 1 insertion(+) diff --git a/maestrowf/datastructures/core/executiongraph.py b/maestrowf/datastructures/core/executiongraph.py index 40b0a7ab..4dd2f360 100644 --- a/maestrowf/datastructures/core/executiongraph.py +++ b/maestrowf/datastructures/core/executiongraph.py @@ -837,6 +837,7 @@ def execute_ready_steps(self): LOGGER.info("Step '%s' was cancelled.", name) self.in_progress.remove(name) record.mark_end(State.CANCELLED) + cleanup_steps.update(self.bfs_subtree(name)[0]) # Let's handle all the failed steps in one go. for node in cleanup_steps: