@@ -54,6 +54,7 @@ def _execute_process(
5454 )
5555
5656 if completion_callback or completion_trigger :
57+
5758 def trigger_check (
5859 completion_callback : typing .Optional [CompletionCallback ],
5960 trigger_to_set : typing .Optional [multiprocessing .synchronize .Event ],
@@ -77,7 +78,8 @@ def trigger_check(
7778 )
7879
7980 thread_out = threading .Thread (
80- target = trigger_check , args = (completion_callback , completion_trigger , _result )
81+ target = trigger_check ,
82+ args = (completion_callback , completion_trigger , _result ),
8183 )
8284 thread_out .start ()
8385
@@ -109,9 +111,7 @@ def __init__(self, simvue_runner: "simvue.Run", keep_logs: bool = True) -> None:
109111 self ._completion_triggers : dict [
110112 str , typing .Optional [multiprocessing .synchronize .Event ]
111113 ] = {}
112- self ._completion_processes : dict [
113- str , typing .Optional [threading .Thread ]
114- ] = {}
114+ self ._completion_processes : dict [str , typing .Optional [threading .Thread ]] = {}
115115 self ._alert_ids : dict [str , str ] = {}
116116 self .command_str : dict [str , str ] = {}
117117 self ._processes : dict [str , subprocess .Popen ] = {}
@@ -246,7 +246,12 @@ def callback_function(status_code: int, std_out: str, std_err: str) -> None:
246246
247247 self ._processes [identifier ], self ._completion_processes [identifier ] = (
248248 _execute_process (
249- identifier , command , self ._runner .name , completion_callback , completion_trigger , env
249+ identifier ,
250+ command ,
251+ self ._runner .name ,
252+ completion_callback ,
253+ completion_trigger ,
254+ env ,
250255 )
251256 )
252257
@@ -409,7 +414,6 @@ def kill_process(
409414 process .kill ()
410415 process .wait ()
411416
412-
413417 def kill_all (self ) -> None :
414418 """Kill all running processes"""
415419 for process in self ._processes .keys ():
0 commit comments