From: Michael Tremer <michael.tremer@ipfire.org>
Date: Wed, 7 Jun 2023 12:32:39 +0000 (+0000)
Subject: sources: Run jobs after fetching commits
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=00e8b48e5e86ff562603683c95b68adf7539ac44;p=pbs.git

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 cc18a3e2..f7abde7f 100644
--- 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):