Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>
Performs a dependency check on all given jobs concurrently
"""
if jobs:
- await asyncio.gather(*(job.depcheck() for job in jobs))
+ results = await asyncio.gather(*(job.depcheck() for job in jobs))
+
+ # Try to dispatch any jobs afterwards
+ if any(results):
+ await self.backend.jobs.queue.dispatch()
+
class Queue(base.Object):
# Store the timestamp
self._set_attribute_now("depcheck_performed_at")
+ # Return the status
+ return self.depcheck_succeeded
+
@property
def depcheck_succeeded(self):
return self.data.depcheck_succeeded