diff --git a/ipsframework/services.py b/ipsframework/services.py index 2827a3d4..7d6967b5 100644 --- a/ipsframework/services.py +++ b/ipsframework/services.py @@ -2240,7 +2240,8 @@ def get_dask_finished_tasks_status(self): self.services.exception('Error while reading dask worker log files: %s', str(e)) else: for worker in worker_names: - os.remove(self.worker_event_logfile.format(worker)) + if os.path.isfile(self.worker_event_logfile.format(worker)): + os.remove(self.worker_event_logfile.format(worker)) self.finished_tasks = {} self.active_tasks = {}