diff --git a/src/handler.py b/src/handler.py index 56ee386..0956c8f 100644 --- a/src/handler.py +++ b/src/handler.py @@ -188,7 +188,7 @@ async def handler_streaming(job: dict) -> Generator[dict[str, list], None, None] } -def concurrency_modifier() -> int: +def concurrency_modifier(current_concurrency) -> int: return os.environ.get('CONCURRENCY_MODIFIER', 100)