From ce8974184eedd9930bc7486cd4e9d47a2c69b350 Mon Sep 17 00:00:00 2001 From: Riccardo Murri Date: Mon, 22 Jan 2018 16:03:09 +0100 Subject: [PATCH] Engine.progress(): FOrget `TERMINATED` tasks even if no `TERMINATING` tasks were handled. --- gc3libs/core.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/gc3libs/core.py b/gc3libs/core.py index d4f5813a..dacfa622 100755 --- a/gc3libs/core.py +++ b/gc3libs/core.py @@ -1889,10 +1889,10 @@ def progress(self): for index in reversed(transitioned): del self._terminating[index] - # now remove all terminated tasks - if self.forget_terminated: - for task in self._terminated: - self._drop_terminated_task(task) + # now remove all terminated tasks + if self.forget_terminated: + for task in self._terminated: + self._drop_terminated_task(task) def _drop_terminated_task(self, task): assert task.execution.state == Run.State.TERMINATED