When the WorkflowKillSwitch exception reaches the TaskQueue, try to prevent pending tasks from starting by simply draining the queue. This is a very loose policy, but since kill switch response is handled at the job level, any tasks that start after the kill switch is activated will take care of themselves and self terminate

Author: AlexTate

cwltool/task_queue.py

@@ -8,6 +8,7 @@
 from typing import Callable, Optional
 
 from .loghandler import _logger
+from .errors import WorkflowKillSwitch
 
 
 class TaskQueue:
@@ -55,6 +56,9 @@ def _task_queue_func(self) -> None:
                 return
             try:
                 task()
+            except WorkflowKillSwitch:
+                self.drain()
+                break
             except BaseException as e:  # noqa: B036
                 _logger.exception("Unhandled exception running task", exc_info=e)
                 self.error = e