wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Remove an unnecessary check in SyncParallelPipeline

Browse Source
This commit is contained in:
Paul Kompfner
2026-03-23 10:00:32 -04:00
parent ec3bd8c5b1
commit e93b0ace06
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/pipecat/pipeline/sync_parallel_pipeline.py
View File

@@ -263,11 +263,11 @@ class SyncParallelPipeline(BasePipeline):
"""
await super().process_frame(frame, direction)
# SystemFrames (but not EndFrame) are simply passed through all
# internal pipelines without draining queued output. This avoids
# the race condition where a SystemFrame's wait_for_sync steals
# frames from a concurrent non-SystemFrame's wait_for_sync.
if isinstance(frame, SystemFrame) and not isinstance(frame, EndFrame):
# SystemFrames are simply passed through all internal pipelines without
# draining queued output. This avoids the race condition where a
# SystemFrame's wait_for_sync steals frames from a concurrent
# non-SystemFrame's wait_for_sync.
if isinstance(frame, SystemFrame):
if direction == FrameDirection.UPSTREAM:
for s in self._sinks:
await s["processor"].process_frame(frame, direction)