This commit is contained in:
@@ -68,7 +68,7 @@ async def docker_build_task(dockerfile: str, target: str) -> int | None:
|
|||||||
return r
|
return r
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
semaphore = asyncio.Semaphore(5)
|
semaphore = asyncio.Semaphore(20)
|
||||||
|
|
||||||
async def limited_task[T: Any](semaphore: asyncio.Semaphore, task: Callable[[], Coroutine[None, None, T]]) -> T:
|
async def limited_task[T: Any](semaphore: asyncio.Semaphore, task: Callable[[], Coroutine[None, None, T]]) -> T:
|
||||||
async with semaphore:
|
async with semaphore:
|
||||||
|
|||||||
Reference in New Issue
Block a user