This is an automated email from the ASF dual-hosted git repository. abderrahim pushed a commit to branch abderrahim/no-query-pipeline in repository https://gitbox.apache.org/repos/asf/buildstream.git
commit 7c3f0f7690212c818e67eff08a18e6cce145403b Author: Abderrahim Kitouni <[email protected]> AuthorDate: Sun Oct 11 20:04:39 2026 +0100 _stream: Query the cache for elements as part of the pipeline --- src/buildstream/_stream.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/buildstream/_stream.py b/src/buildstream/_stream.py index a1d88d667..a46470430 100644 --- a/src/buildstream/_stream.py +++ b/src/buildstream/_stream.py @@ -416,14 +416,14 @@ class Stream: source_push_enabled = self._sourcecache.has_push_remotes() - # If source push is enabled, the source cache status of all elements - # is required, independent of whether the artifact is already available. - self.query_cache(elements, sources_of_cached_elements=source_push_enabled) - # Now construct the queues # self._reset() + # If source push is enabled, the source cache status of all elements + # is required, independent of whether the artifact is already available. + self._add_queue(CacheQueryQueue(self._scheduler, sources_if_cached=source_push_enabled)) + if self._artifacts.has_fetch_remotes(): self._add_queue(PullQueue(self._scheduler))
