We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 4be89d1 + 370fdcb commit 3255123Copy full SHA for 3255123
ipsframework/services.py
@@ -2240,7 +2240,8 @@ def get_dask_finished_tasks_status(self):
2240
self.services.exception('Error while reading dask worker log files: %s', str(e))
2241
else:
2242
for worker in worker_names:
2243
- os.remove(self.worker_event_logfile.format(worker))
+ if os.path.isfile(self.worker_event_logfile.format(worker)):
2244
+ os.remove(self.worker_event_logfile.format(worker))
2245
2246
self.finished_tasks = {}
2247
self.active_tasks = {}
0 commit comments