This commit is contained in:
@@ -40,7 +40,7 @@ async def docker_push(image: str) -> int | None:
|
|||||||
print(f"Pushing image {image}...")
|
print(f"Pushing image {image}...")
|
||||||
return await run_command(f"docker push {image}")
|
return await run_command(f"docker push {image}")
|
||||||
|
|
||||||
semaphore = asyncio.Semaphore(5)
|
semaphore = asyncio.Semaphore(50)
|
||||||
|
|
||||||
async def limited_task[T: Any](task: Callable[[], Coroutine[None, None, T]]) -> T:
|
async def limited_task[T: Any](task: Callable[[], Coroutine[None, None, T]]) -> T:
|
||||||
async with semaphore:
|
async with semaphore:
|
||||||
|
|||||||
Reference in New Issue
Block a user