diff options
Diffstat (limited to 'buildstream/_scheduler/queues/fetchqueue.py')
| -rw-r--r-- | buildstream/_scheduler/queues/fetchqueue.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/buildstream/_scheduler/queues/fetchqueue.py b/buildstream/_scheduler/queues/fetchqueue.py index c58bfdb57..fc11fd1d1 100644 --- a/buildstream/_scheduler/queues/fetchqueue.py +++ b/buildstream/_scheduler/queues/fetchqueue.py @@ -24,6 +24,7 @@ from ... import Consistency # Local imports from . import Queue, QueueStatus from ..resources import ResourceType +from ..jobs import JobStatus # A queue which fetches element sources @@ -66,9 +67,9 @@ class FetchQueue(Queue): return QueueStatus.READY - def done(self, _, element, result, success): + def done(self, _, element, result, status): - if not success: + if status == JobStatus.FAIL: return element._update_state() |