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

processors: fix input queue interruptions

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-11-06 13:12:24 -08:00
parent b6f0c16591
commit a9e565f355
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/pipecat/processors/frame_processor.py
View File

@@ -217,18 +217,18 @@ class FrameProcessor:
# #
async def _start_interruption(self): async def _start_interruption(self):
# Cancel the input task. This will stop processing queued frames.
await self.__cancel_input_task()
# Cancel the push frame task. This will stop pushing frames downstream. # Cancel the push frame task. This will stop pushing frames downstream.
await self.__cancel_push_task() await self.__cancel_push_task()
# Create a new output queue and task. # Cancel the input task. This will stop processing queued frames.
self.__create_push_task() await self.__cancel_input_task()
# Create a new input queue and task. # Create a new input queue and task.
self.__create_input_task() self.__create_input_task()
# Create a new output queue and task.
self.__create_push_task()
async def _stop_interruption(self): async def _stop_interruption(self):
# Nothing to do right now. # Nothing to do right now.
pass pass