@@ -2283,7 +2283,8 @@ def refresh_log_recovery_process(platforms: list[Platform], as_conf: AutosubmitC
22832283 if not p .log_recovery_process or not p .log_recovery_process .is_alive ():
22842284 p .clean_log_recovery_process ()
22852285 p .spawn_log_retrieval_process (as_conf )
2286- p .work_event .set ()
2286+ if p .work_event :
2287+ p .work_event .set ()
22872288
22882289 @staticmethod
22892290 def run_experiment (expid : str , start_time : Optional [str ] = None , start_after : Optional [str ] = None ,
@@ -2436,9 +2437,9 @@ def run_experiment(expid: str, start_time: Optional[str] = None, start_after: Op
24362437 job_list .save ()
24372438 as_conf .save ()
24382439 time .sleep (safetysleeptime )
2439- except AutosubmitError as e : # If an error is detected, restore all connections and job_list
2440- Log .error (f"Trace: { e .trace } " )
2441- Log .error (f"{ e .message } [eCode={ e .code } ]" )
2440+ except AutosubmitError as ae : # If an error is detected, restore all connections and job_list
2441+ Log .error (f"Trace: { ae .trace } " )
2442+ Log .error (f"{ ae .message } [eCode={ ae .code } ]" )
24422443 # No need to wait until the remote platform reconnection
24432444 recovery = False
24442445 as_conf = AutosubmitConfig (expid , BasicConfig , YAMLParserFactory ())
@@ -2509,8 +2510,9 @@ def run_experiment(expid: str, start_time: Optional[str] = None, start_after: Op
25092510 except BaseException :
25102511 reconnected = False
25112512 if recovery_retrials == max_recovery_retrials and max_recovery_retrials > 0 :
2512- raise AutosubmitCritical (f"Autosubmit Encounter too much errors during running time, limit of { max_recovery_retrials * 120 } reached" ,
2513- 7051 , e .message )
2513+ raise AutosubmitCritical (
2514+ f"Autosubmit Encounter too much errors during running time, limit of { max_recovery_retrials * 120 } reached" ,
2515+ 7051 , ae .message )
25142516 except AutosubmitCritical as e : # Critical errors can't be recovered. Failed configuration or autosubmit error
25152517 raise AutosubmitCritical (e .message , e .code , e .trace )
25162518 except BaseException :
0 commit comments