diff options
| author | Jürg Billeter <j@bitron.ch> | 2019-06-19 14:48:05 +0200 |
|---|---|---|
| committer | Jürg Billeter <j@bitron.ch> | 2019-06-24 15:33:49 +0200 |
| commit | 33b0c270cebb6be5b8025f18d26ba4710d4c05a1 (patch) | |
| tree | 78d7bcd50a7161cc9458b7442947fde82ce62589 | |
| parent | 979e3494b4921652ac0e624e1346567ddecac5c3 (diff) | |
| download | buildstream-juerg/fetch-subprojects.tar.gz | |
_stream.py: Use scheduler to fetch subprojectsjuerg/fetch-subprojects
| -rw-r--r-- | src/buildstream/_stream.py | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/src/buildstream/_stream.py b/src/buildstream/_stream.py index 650202d21..a7db33bb9 100644 --- a/src/buildstream/_stream.py +++ b/src/buildstream/_stream.py @@ -961,8 +961,14 @@ class Stream(): # junctions (list of Element): The junctions to fetch # def fetch_subprojects(self, junctions): - for junction in junctions: - junction._fetch() + old_queues = self.queues + try: + queue = FetchQueue(self._scheduler) + queue.enqueue(junctions) + self.queues = [queue] + self._run() + finally: + self.queues = old_queues ############################################################# # Scheduler API forwarding # |