diff --git a/src/pipecat/pipeline/sync_parallel_pipeline.py b/src/pipecat/pipeline/sync_parallel_pipeline.py
index 7fa3577a5..083e992ca 100644
--- a/src/pipecat/pipeline/sync_parallel_pipeline.py
+++ b/src/pipecat/pipeline/sync_parallel_pipeline.py
@@ -78,16 +78,18 @@ class SyncParallelPipeline(BasePipeline):
             down_queue = asyncio.Queue()
             source = SyncParallelPipelineSource(up_queue)
             sink = SyncParallelPipelineSink(down_queue)
-            processors: List[FrameProcessor] = [source] + processors + [sink]
+
+            # Create pipeline
+            pipeline = Pipeline(processors)
+            source.link(pipeline)
+            pipeline.link(sink)
+            self._pipelines.append(pipeline)
 
             # Keep track of sources and sinks. We also keep the output queue of
             # the source and the sinks so we can use it later.
             self._sources.append({"processor": source, "queue": down_queue})
             self._sinks.append({"processor": sink, "queue": up_queue})
 
-            # Create pipeline
-            pipeline = Pipeline(processors)
-            self._pipelines.append(pipeline)
         logger.debug(f"Finished creating {self} pipelines")
 
     #