"""
return self.build.build_repo.pakfire(arch=self.arch, **kwargs)
+ # Perform only four dependency checks at a time
+ __depcheck_ratelimiter = asyncio.Semaphore(4)
+
async def depcheck(self):
"""
Perform dependency check
"""
- log.info("Performing dependency check for %s (%s)" % (self, self.uuid))
+ with self.__depcheck_ratelimiter:
+ log.info("Performing dependency check for %s (%s)" % (self, self.uuid))
- with self.db.transaction():
- return await asyncio.to_thread(self._depcheck)
+ with self.db.transaction():
+ return await asyncio.to_thread(self._depcheck)
def _depcheck(self):
# Create a Pakfire instance