fix

jan-janssen · jan-janssen · commit c2b7af476fe9 · 2026-01-28T16:30:33.000+01:00
diff --git a/src/executorlib/task_scheduler/file/shared.py b/src/executorlib/task_scheduler/file/shared.py
@@ -100,7 +100,7 @@ def execute_tasks_h5(
                         for key, value in memory_dict.items()
                         if not value.done()
                     }
-            if task_dict["cancel_futures"] and cancel_futures_on_shutdown:
+            if task_dict["cancel_futures"] or cancel_futures_on_shutdown:
                 if (
                     terminate_function is not None
                     and terminate_function == terminate_subprocess

Original file line number	Diff line number	Diff line change
`@@ -100,7 +100,7 @@ def execute_tasks_h5(`
`100`	`100`	`for key, value in memory_dict.items()`
`101`	`101`	`if not value.done()`
`102`	`102`	`}`
`103`		`- if task_dict["cancel_futures"] and cancel_futures_on_shutdown:`
	`103`	`+ if task_dict["cancel_futures"] or cancel_futures_on_shutdown:`
`104`	`104`	`if (`
`105`	`105`	`terminate_function is not None`
`106`	`106`	`and terminate_function == terminate_subprocess`