diff options
Diffstat (limited to 'src/buildstream/_stream.py')
-rw-r--r-- | src/buildstream/_stream.py | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/src/buildstream/_stream.py b/src/buildstream/_stream.py index 0aff5fb94..dc76edad9 100644 --- a/src/buildstream/_stream.py +++ b/src/buildstream/_stream.py @@ -163,6 +163,18 @@ class Stream: return target_objects + # query_cache() + # + # Query the artifact and source caches to determine the cache status + # of the specified elements. + # + # Args: + # elements (list of Element): The elements to check + # + def query_cache(self, elements): + # Cache is implicitly queried on demand + pass + # shell() # # Run a shell @@ -614,6 +626,8 @@ class Stream: targets, selection=selection, use_artifact_config=True, load_artifacts=True ) + self.query_cache(target_objects) + if self._artifacts.has_fetch_remotes(): self._pipeline.check_remotes(target_objects) @@ -633,6 +647,8 @@ class Stream: # Return list of Element and/or ArtifactElement objects target_objects = self.load_selection(targets, selection=_PipelineSelection.NONE, load_artifacts=True) + self.query_cache(target_objects) + artifact_logs = {} for obj in target_objects: ref = obj.get_artifact_name() @@ -661,6 +677,8 @@ class Stream: # Return list of Element and/or ArtifactElement objects target_objects = self.load_selection(targets, selection=_PipelineSelection.NONE, load_artifacts=True) + self.query_cache(target_objects) + elements_to_files = {} for obj in target_objects: ref = obj.get_artifact_name() |