You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@buildstream.apache.org by ro...@apache.org on 2020/12/29 13:30:22 UTC

[buildstream] 24/32: pullqueue.py: Add resources

This is an automated email from the ASF dual-hosted git repository.

root pushed a commit to branch testing/local-cache-expiry
in repository https://gitbox.apache.org/repos/asf/buildstream.git

commit 7162f09dfdb8adec6a28ff6c2a2bb183a157d53a
Author: Tristan Maat <tm...@tlater.net>
AuthorDate: Wed Jul 11 10:33:51 2018 +0100

    pullqueue.py: Add resources
---
 buildstream/_scheduler/queues/pullqueue.py | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/buildstream/_scheduler/queues/pullqueue.py b/buildstream/_scheduler/queues/pullqueue.py
index 20e7843..430afc4 100644
--- a/buildstream/_scheduler/queues/pullqueue.py
+++ b/buildstream/_scheduler/queues/pullqueue.py
@@ -19,8 +19,8 @@
 #        Jürg Billeter <ju...@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