File tree Expand file tree Collapse file tree 2 files changed +12
-5
lines changed
Expand file tree Collapse file tree 2 files changed +12
-5
lines changed Original file line number Diff line number Diff line change @@ -1080,8 +1080,7 @@ def _poll_jobs(self) -> tuple[int, bool]: # noqa: C901
10801080 )
10811081 for job_meta in done_jobs :
10821082 # Free up resources
1083- if not self ._delete_task_file_on_load :
1084- job_meta .pickle_fname .unlink ()
1083+ job_meta .pickle_fname .unlink (missing_ok = True )
10851084 run_fname = job_meta .pickle_fname .with_suffix (".run" )
10861085 if self ._export_metadata :
10871086 # Update run from file again
Original file line number Diff line number Diff line change @@ -127,9 +127,17 @@ def logger_level(arg):
127127 try :
128128 logger .info ("Deleting file containing DelayedSubmission object." )
129129 fname .unlink ()
130- logger .info (
131- f"Deleted file { fname } ."
132- )
130+ logger .info (f"Deleted file { fname } ." )
131+ # Best-effort cleanup of associated lock file (<task>.lock)
132+ lock_fname = fname .parent / (fname .name + ".lock" )
133+ try :
134+ lock_fname .unlink (missing_ok = True )
135+ logger .info (f"Deleted lock file { lock_fname } ." )
136+ except RuntimeError as e :
137+ logger .warning (
138+ f"Could not delete lock file { lock_fname } after loading "
139+ f"DelayedSubmission. Error: { e } "
140+ )
133141 except RuntimeError as e :
134142 logger .warning (
135143 f"Could not delete file { fname } after loading "
You can’t perform that action at this time.
0 commit comments