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