File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
executorlib/task_scheduler/file Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change 1313from executorlib .task_scheduler .file .shared import execute_tasks_h5
1414from executorlib .task_scheduler .file .subprocess_spawner import (
1515 execute_in_subprocess ,
16- terminate_subprocess ,
1716)
1817
1918try :
@@ -58,8 +57,6 @@ def __init__(
5857 resource_dict .update (
5958 {k : v for k , v in default_resource_dict .items () if k not in resource_dict }
6059 )
61- if execute_function == execute_in_subprocess and terminate_function is None :
62- terminate_function = terminate_subprocess
6360 self ._process_kwargs = {
6461 "resource_dict" : resource_dict ,
6562 "future_queue" : self ._future_queue ,
@@ -93,6 +90,7 @@ def create_file_executor(
9390 init_function : Optional [Callable ] = None ,
9491 disable_dependencies : bool = False ,
9592 execute_function : Callable = execute_with_pysqa ,
93+ terminate_function : Optional [Callable ] = None ,
9694):
9795 if block_allocation :
9896 raise ValueError (
@@ -116,4 +114,5 @@ def create_file_executor(
116114 backend = backend ,
117115 disable_dependencies = disable_dependencies ,
118116 execute_function = execute_function ,
117+ terminate_function = terminate_function ,
119118 )
You can’t perform that action at this time.
0 commit comments