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

move wait_time out of loop

Browse Source
This commit is contained in:
OmercohenAviv
2026-03-29 00:05:21 +03:00
parent 2724ef6d6f
commit f2e0f5d20c
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -967,9 +967,9 @@ class PipelineTask(BasePipelineTask):
the time that a heartbeat frame takes to processes, that is how long it the time that a heartbeat frame takes to processes, that is how long it
takes for the heartbeat frame to traverse all the pipeline. takes for the heartbeat frame to traverse all the pipeline.
""" """
wait_time = self._params.heartbeats_monitor_secs
while True: while True:
try: try:
wait_time = self._params.heartbeats_monitor_secs
frame = await asyncio.wait_for(self._heartbeat_queue.get(), timeout=wait_time) frame = await asyncio.wait_for(self._heartbeat_queue.get(), timeout=wait_time)
process_time = (self._clock.get_time() - frame.timestamp) / 1_000_000_000 process_time = (self._clock.get_time() - frame.timestamp) / 1_000_000_000
logger.trace(f"{self}: heartbeat frame processed in {process_time} seconds") logger.trace(f"{self}: heartbeat frame processed in {process_time} seconds")