File tree Expand file tree Collapse file tree 3 files changed +9
-3
lines changed
task_scheduler/interactive Expand file tree Collapse file tree 3 files changed +9
-3
lines changed Original file line number Diff line number Diff line change @@ -78,7 +78,9 @@ def receive_dict(self) -> dict:
7878 while len (response_lst ) == 0 :
7979 response_lst = self ._poller .poll (self ._time_out_ms )
8080 if not self ._spawner .poll ():
81- raise ExecutorlibSocketError ("SocketInterface crashed during execution." )
81+ raise ExecutorlibSocketError (
82+ "SocketInterface crashed during execution."
83+ )
8284 data = self ._socket .recv (zmq .NOBLOCK )
8385 if self ._logger is not None :
8486 self ._logger .warning (
Original file line number Diff line number Diff line change @@ -257,7 +257,9 @@ def _execute_multiple_tasks(
257257 while True :
258258 if not interface .status and restart_counter > restart_limit :
259259 interface .status = True # no more restarts
260- interface_initialization_exception = ExecutorlibSocketError ("SocketInterface crashed during execution." )
260+ interface_initialization_exception = ExecutorlibSocketError (
261+ "SocketInterface crashed during execution."
262+ )
261263 elif not interface .status :
262264 interface .bootup ()
263265 interface_initialization_exception = _set_init_function (
Original file line number Diff line number Diff line change @@ -275,4 +275,6 @@ def _execute_task_in_thread(
275275 cache_key = cache_key ,
276276 error_log_file = error_log_file ,
277277 ):
278- future_obj .set_exception (ExecutorlibSocketError ("SocketInterface crashed during execution." ))
278+ future_obj .set_exception (
279+ ExecutorlibSocketError ("SocketInterface crashed during execution." )
280+ )
You can’t perform that action at this time.
0 commit comments