diff options
| author | Tristan Maat <tm@tlater.net> | 2018-07-11 10:33:51 +0100 |
|---|---|---|
| committer | Tristan Maat <tm@tlater.net> | 2018-07-11 11:28:28 +0100 |
| commit | 7162f09dfdb8adec6a28ff6c2a2bb183a157d53a (patch) | |
| tree | db298758d17f168603b19d818b52f3acdfda60a9 | |
| parent | b356a61385279b60ffe7dfbe4ae8cf8402347e9e (diff) | |
| download | buildstream-7162f09dfdb8adec6a28ff6c2a2bb183a157d53a.tar.gz | |
pullqueue.py: Add resources
| -rw-r--r-- | buildstream/_scheduler/queues/pullqueue.py | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/buildstream/_scheduler/queues/pullqueue.py b/buildstream/_scheduler/queues/pullqueue.py index 20e784391..430afc410 100644 --- a/buildstream/_scheduler/queues/pullqueue.py +++ b/buildstream/_scheduler/queues/pullqueue.py @@ -19,8 +19,8 @@ # Jürg Billeter <juerg.billeter@codethink.co.uk> # Local imports -from . import Queue, QueueStatus, QueueType -from ..jobs import JobType +from . import Queue, QueueStatus +from ..resources import ResourceType # A queue which pulls element artifacts @@ -29,8 +29,7 @@ class PullQueue(Queue): action_name = "Pull" complete_name = "Pulled" - queue_type = QueueType.FETCH - job_type = JobType.PULL + resources = [ResourceType.UPLOAD] def process(self, element): # returns whether an artifact was downloaded or not |