Skip to content

Commit

Permalink
Engine.progress(): FOrget TERMINATED tasks even if no TERMINATING
Browse files Browse the repository at this point in the history
… tasks were handled.
  • Loading branch information
riccardomurri committed Jan 22, 2018
1 parent 41a6bed commit ce89741
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions gc3libs/core.py
Expand Up @@ -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
Expand Down

0 comments on commit ce89741

Please sign in to comment.