]> git.ipfire.org Git - pbs.git/commitdiff
sources: Run jobs after fetching commits
authorMichael Tremer <michael.tremer@ipfire.org>
Wed, 7 Jun 2023 12:32:39 +0000 (12:32 +0000)
committerMichael Tremer <michael.tremer@ipfire.org>
Wed, 7 Jun 2023 12:32:39 +0000 (12:32 +0000)
Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>
src/buildservice/sources.py

index cc18a3e2871eea550efdf0d4c39ecf29a1573780..f7abde7f7c2e9e809a24932f580b59ef47678b0e 100644 (file)
@@ -130,7 +130,7 @@ class Sources(base.Object):
 
        # Fetch
 
-       async def fetch(self):
+       async def fetch(self, run_jobs=True):
                """
                        Fetches any new commits from all sources
                """
@@ -139,6 +139,10 @@ class Sources(base.Object):
                        for source in self:
                                tg.create_task(source.fetch())
 
+               # Process any pending jobs
+               if run_jobs:
+                       await self.run_jobs()
+
        # Run jobs
 
        def _get_jobs(self, query, *args, **kwargs):