diff options
Diffstat (limited to 'src/buildstream/_scheduler/queues/cachequeryqueue.py')
-rw-r--r-- | src/buildstream/_scheduler/queues/cachequeryqueue.py | 14 |
1 files changed, 8 insertions, 6 deletions
diff --git a/src/buildstream/_scheduler/queues/cachequeryqueue.py b/src/buildstream/_scheduler/queues/cachequeryqueue.py index 7ed7dcede..b9f425966 100644 --- a/src/buildstream/_scheduler/queues/cachequeryqueue.py +++ b/src/buildstream/_scheduler/queues/cachequeryqueue.py @@ -29,10 +29,10 @@ class CacheQueryQueue(Queue): resources = [ResourceType.CACHE] def get_process_func(self): - if self._query_artifacts: + if True: # self._query_artifacts: return CacheQueryQueue._query_artifacts_or_sources else: - return CacheQueryQueue._query_sources + return None # CacheQueryQueue._query_sources def status(self, element): if not element._get_cache_key(strength=_KeyStrength.WEAK): @@ -46,14 +46,16 @@ class CacheQueryQueue(Queue): if status is JobStatus.FAIL: return - element._cache_query_done() + if not element._pull_pending(): + element._load_artifact_done() @staticmethod def _query_artifacts_or_sources(element): - element._query_cache() + element._load_artifact(pull=False) if not element._can_query_cache() or not element._cached_success(): - element._query_source_cache() + pass # element._query_source_cache() @staticmethod def _query_sources(element): - element._query_source_cache() + # element._query_source_cache() + pass |