wip

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