File tree Expand file tree Collapse file tree
executorlib/task_scheduler/file Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -58,8 +58,6 @@ def __init__(
5858 resource_dict .update (
5959 {k : v for k , v in default_resource_dict .items () if k not in resource_dict }
6060 )
61- if execute_function == execute_in_subprocess and terminate_function is None :
62- terminate_function = terminate_subprocess
6361 self ._process_kwargs = {
6462 "resource_dict" : resource_dict ,
6563 "future_queue" : self ._future_queue ,
@@ -93,6 +91,7 @@ def create_file_executor(
9391 init_function : Optional [Callable ] = None ,
9492 disable_dependencies : bool = False ,
9593 execute_function : Callable = execute_with_pysqa ,
94+ terminate_function : Optional [Callable ] = None ,
9695):
9796 if block_allocation :
9897 raise ValueError (
@@ -116,4 +115,5 @@ def create_file_executor(
116115 backend = backend ,
117116 disable_dependencies = disable_dependencies ,
118117 execute_function = execute_function ,
118+ terminate_function = terminate_function ,
119119 )
You can’t perform that action at this time.
0 commit comments