_stream.py: Add internal _resolve_remotely_cached()

This replaces the corresponding Pipeline method `check_remotes()`.

1 files changed, 16 insertions, 1 deletions

diff --git a/src/buildstream/_stream.py b/src/buildstream/_stream.py
index e05100f24..1dab4a3f0 100644
--- a/src/buildstream/_stream.py
+++ b/src/buildstream/_stream.py
@@ -618,7 +618,7 @@ class Stream:
         )
 
         if self._artifacts.has_fetch_remotes():
-            self._pipeline.check_remotes(target_objects)
+            self._resolve_cached_remotely(target_objects)
 
         return target_objects
 
@@ -1205,6 +1205,21 @@ class Stream:
         self._elementsourcescache.setup_remotes(use_config=use_source_config, remote_url=source_url)
         self._sourcecache.setup_remotes(use_config=use_source_config, remote_url=source_url)
 
+    # _resolve_cached_remotely()
+    #
+    # Checks whether the listed elements are currently cached in
+    # any of their respectively configured remotes.
+    #
+    # Args:
+    #    targets (list [Element]): The list of element targets
+    #
+    def _resolve_cached_remotely(self, targets):
+        with self._context.messenger.simple_task("Querying remotes for cached status", silent_nested=True) as task:
+            task.set_maximum_progress(len(targets))
+            for element in targets:
+                element._cached_remotely()
+                task.add_current_progress()
+
     # _load_tracking()
     #
     # A variant of _load() to be used when the elements should be used