diff --git a/kpops/pipeline/__init__.py b/kpops/pipeline/__init__.py index c874801aa..d6b545c94 100644 --- a/kpops/pipeline/__init__.py +++ b/kpops/pipeline/__init__.py @@ -109,7 +109,7 @@ def build_execution_graph( async def run_parallel_tasks( coroutines: list[Coroutine[Any, Any, None]], ) -> None: - tasks = [] + tasks: list[asyncio.Task[None]] = [] for coro in coroutines: tasks.append(asyncio.create_task(coro)) await asyncio.gather(*tasks)