File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -87,7 +87,7 @@ def setup_engine_remote(self):
8787
8888 def shutdown_remote (self ):
8989 logger_debug (f"Shutting down rpc remote" , color = "yellow" )
90- self .rpc_client .shutdown ().remote ()
90+ self .rpc_client .shutdown ().remote (need_response = False )
9191
9292 def abort_request (self , request_id : int ) -> None :
9393 return self .rpc_client .abort_request (request_id ).remote ()
@@ -117,7 +117,9 @@ def shutdown(self):
117117 # (e.g., during garbage collection in that thread)
118118 if self .main_loop_thread and threading .current_thread (
119119 ) != self .main_loop_thread :
120- self .main_loop_thread .join ()
120+ self .main_loop_thread .join (timeout = 2.0 )
121+ if self .main_loop_thread .is_alive ():
122+ logger .warning ("Main loop thread did not exit gracefully" )
121123
122124 # 3. shutdown the mpi session, this should wait until all the PyExecutor
123125 # processes are shutdown
You can’t perform that action at this time.
0 commit comments