Use create tasks and not gather

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: