SyncParallelPipeline: don't add source/sink processors inside pipeline

This commit is contained in:
Aleix Conchillo Flaqué
2025-01-30 13:11:36 -08:00
parent 85e572e2d8
commit 241f241ed9

View File

@@ -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")
#