sources: Run jobs after fetching commits

Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>

diff --git a/src/buildservice/sources.py b/src/buildservice/sources.py
index cc18a3e2871eea550efdf0d4c39ecf29a1573780..f7abde7f7c2e9e809a24932f580b59ef47678b0e 100644 (file)
--- a/src/buildservice/sources.py
+++ b/src/buildservice/sources.py
@@ -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):