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

task: add HEARTBEAT_MONITOR_SECONDS

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-01-17 10:11:28 -08:00
parent 477d0d154b
commit 45cbad5b3e
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/pipecat/pipeline/task.py
View File

@@ -31,6 +31,7 @@ from pipecat.processors.frame_processor import FrameDirection, FrameProcessor
from pipecat.utils.utils import obj_count, obj_id from pipecat.utils.utils import obj_count, obj_id
HEARTBEAT_SECONDS = 1.0 HEARTBEAT_SECONDS = 1.0
HEARTBEAT_MONITOR_SECONDS = HEARTBEAT_SECONDS * 5
class PipelineParams(BaseModel): class PipelineParams(BaseModel):
@@ -353,7 +354,7 @@ class PipelineTask:
takes for the heartbeat frame to traverse all the pipeline. takes for the heartbeat frame to traverse all the pipeline.
""" """
wait_time = HEARTBEAT_SECONDS * 5 wait_time = HEARTBEAT_MONITOR_SECONDS
while True: while True:
try: try:
frame = await asyncio.wait_for(self._heartbeat_queue.get(), timeout=wait_time) frame = await asyncio.wait_for(self._heartbeat_queue.get(), timeout=wait_time)