diff --git a/kpops/pipeline_generator/pipeline.py b/kpops/pipeline_generator/pipeline.py
index 50257db11..1b28422a1 100644
--- a/kpops/pipeline_generator/pipeline.py
+++ b/kpops/pipeline_generator/pipeline.py
@@ -87,7 +87,7 @@ def build_execution_graph_from(
         runner: Callable[[PipelineComponent], Coroutine],
     ):
         async def run_parallel_tasks(tasks):
-            await asyncio.gather(*tasks)
+            asyncio.create_task(*tasks)
 
         async def run_graph_tasks(pending_tasks: list[Awaitable]):
             for pending_task in pending_tasks: