@@ -333,9 +333,7 @@ def __post_init__(self, test_mode: bool = False):
333333 )
334334 atexit .register (self .clean_old_logs )
335335 # moved validation to validation.py
336- validate_status_command_settings (
337- self .workflow .executor_settings , self .logger
338- )
336+ validate_status_command_settings (self .workflow .executor_settings , self .logger )
339337
340338 def get_status_command (self ):
341339 """Get the status command to use, with fallback logic."""
@@ -616,18 +614,15 @@ async def check_active_jobs(
616614 dynamic_check_threshold = 3 * initial_interval
617615 if status_command_name == "squeue" :
618616 if (
619- min_job_age is None
620- or min_job_age < dynamic_check_threshold
617+ min_job_age is None or min_job_age < dynamic_check_threshold
621618 ) and is_query_tool_available ("sacct" ):
622619 self .logger .info (
623620 "Falling back to 'sacct' for status queries "
624621 f"(MinJobAge={ min_job_age } ; threshold={ dynamic_check_threshold } s)."
625622 )
626623 status_command_name = "sacct"
627624 if status_command_name == "sacct" and not is_query_tool_available ("sacct" ):
628- self .logger .info (
629- "'sacct' unavailable, using 'squeue' for status queries."
630- )
625+ self .logger .info ("'sacct' unavailable, using 'squeue' for status queries." )
631626 status_command_name = "squeue"
632627 if status_command_name == "sacct" :
633628 status_command = query_job_status_sacct (self .run_uuid )
0 commit comments