Aleix Conchillo Flaqué
3e4020cdba
task: add TaskObserver and avoid pipeline blocking
...
Observers now process frames in separate tasks. This avoids blocking the
pipeline while the observer is processing the frame.
2025-01-17 11:15:52 -08:00
Aleix Conchillo Flaqué
4f883ee31f
Merge pull request #1023 from pipecat-ai/aleix/introduce-heartbeat-frames
...
introduce heartbeat frames
2025-01-17 10:31:07 -08:00
Aleix Conchillo Flaqué
45cbad5b3e
task: add HEARTBEAT_MONITOR_SECONDS
2025-01-17 10:11:28 -08:00
Aleix Conchillo Flaqué
477d0d154b
frame_processor: make sure clock is initialized
2025-01-17 10:05:23 -08:00
Aleix Conchillo Flaqué
4b3c776f58
task: don't use push queue to send a heartbeat
...
This is because we might be waiting for the EndFrame. Currently, if we push an
EndFrame to the task, the task will block until the EndFrame traverses all the
pipeline.
2025-01-17 10:04:24 -08:00
Aleix Conchillo Flaqué
da0c4cfd99
task: increase heartbeat monitoring to 5 seconds
2025-01-17 10:04:05 -08:00
Aleix Conchillo Flaqué
f22a00570d
task: start heartbeats task when push task starts
2025-01-17 10:03:13 -08:00
Mark Backman
85f4663a41
Start UserIdleProcessor on speaking frame, fix bug not pushing EndFrame
2025-01-17 12:54:17 -05:00
Vaibhav159
80779c48d6
sort fix
2025-01-17 20:07:25 +05:30
Vaibhav159
c444557965
fixing IdleFrameProcessor and UserIdleProcessor init logic
2025-01-17 19:50:53 +05:30
Mark Backman
0dd22fb879
Merge pull request #1022 from pipecat-ai/mb/fix-abstractmethod
...
Remove @abstractmethod from set_model and set_model in TTSService class
2025-01-16 22:59:26 -05:00
Aleix Conchillo Flaqué
ff8aa68942
introduce heartbeat frames
2025-01-16 19:31:13 -08:00
Aleix Conchillo Flaqué
799777774b
Merge pull request #1018 from pipecat-ai/aleix/streamline-thread-pool-executors
...
transports: streamline max_workers for ThreadPoolExecutors
2025-01-16 19:05:41 -08:00
Mark Backman
fdef8a97e2
Remove @abstractmethod from set_model and set_model in TTSService class
2025-01-16 21:36:51 -05:00
Mark Backman
e805738d4c
Merge pull request #1009 from pipecat-ai/mb/tts-ignore-interim-transcripts
...
TTSService should only process LLMTextFrames
2025-01-16 17:09:24 -05:00
Mark Backman
119bc7e35f
Update check to exclude transcription frames
2025-01-16 16:43:46 -05:00
Aleix Conchillo Flaqué
3714f12edc
Merge pull request #1019 from Canonical-AI-Inc/canonical-transcripts
...
Add transcript to Canonical Metrics Service
2025-01-16 13:36:55 -08:00
Aleix Conchillo Flaqué
d2b8171197
transports: streamline max_workers for ThreadPoolExecutors
2025-01-16 13:34:04 -08:00
Adrian Cowham
d0b48c95bb
updated the example to use stereo audio and pass in the context. also updated the service to send the transcripts if they're available
2025-01-16 13:12:38 -08:00
Aleix Conchillo Flaqué
73ed0c1ad7
Merge pull request #1017 from pipecat-ai/aleix/additional-trace-logging
...
additional trace logging
2025-01-16 12:38:47 -08:00
Aleix Conchillo Flaqué
359b55a85e
additional trace logging
2025-01-16 11:19:42 -08:00
vipyne
8ba3b150eb
services(gemini_multimodal_live): set content to [] if not present in messages
...
... which it will be if the message is a tool call
2025-01-16 11:59:02 -06:00
Mark Backman
67e47a388d
TTSService should only process LLMTextFrames
2025-01-16 10:03:24 -05:00
Aleix Conchillo Flaqué
08f1dda94e
observers: add a timestamp to on_push_frame()
2025-01-15 17:45:00 -08:00
Aleix Conchillo Flaqué
dd9f9179cc
rtvi(RTVIObserver): use observers for RTVI server->client messages
2025-01-15 17:45:00 -08:00
Aleix Conchillo Flaqué
c8da531402
pipeline(task): add support for pipeline frame observers
2025-01-15 17:43:59 -08:00
Aleix Conchillo Flaqué
25bcaf5c7c
observers: introduce pipeline observers
2025-01-15 17:43:59 -08:00
Aleix Conchillo Flaqué
2d0f3341c3
frames: add LLMTextFrame and TTSTextFrame
...
This is to distinguish what type of service has generated the TextFrames.
2025-01-15 17:43:59 -08:00
Aleix Conchillo Flaqué
9dacbbbbf4
fix ruff formatting
2025-01-15 13:02:13 -08:00
Mark Backman
d5df4b064b
Merge pull request #987 from pipecat-ai/mb/deepseek-typo
...
Fix error log in DeepSeekLLMService and CerebrasLLMService
2025-01-15 14:31:34 -05:00
Vaibhav159
d1ac7751da
finalize on DeepgramSTTService
2025-01-15 20:43:23 +05:30
Mark Backman
e815d7776f
Fix error log in DeepSeekLLMService and CerebrasLLMService
2025-01-14 18:03:29 -05:00
sahil suman
7339cc7197
Merge remote-tracking branch 'origin/main' into openrouter-integration
2025-01-15 02:52:19 +05:30
Sahil Suman
329da50338
Update src/pipecat/services/openrouter.py
...
Co-authored-by: Mark Backman <m.backman@gmail.com >
2025-01-15 02:20:22 +05:30
sahil suman
4d307d26d8
made the required changes.
...
Signed-off-by: sahil suman <sahilsuman933@gmail.com >
2025-01-15 02:19:05 +05:30
sahil suman
11381a536f
added example for function calling and made the required changes.
...
Signed-off-by: sahil suman <sahilsuman933@gmail.com >
2025-01-15 01:00:33 +05:30
Mark Backman
b53bc8a879
_calculate_wait_times as private, add and use WebsocketServiceException
2025-01-14 13:20:13 -05:00
Mark Backman
e3d8910814
Update CHANGELOG
2025-01-14 13:12:40 -05:00
Mark Backman
e60a59434f
Refactor LMNTTTSService to make a websocket connection directly, then use the WebsocketService base class
2025-01-14 13:09:58 -05:00
Mark Backman
5e5de618f3
Update PlayHTTTSService to use the WebsocketService base class
2025-01-14 13:09:58 -05:00
Mark Backman
8af92f7923
Update ElevenLabsTTSService to use the WebsocketService base class
2025-01-14 13:09:58 -05:00
Mark Backman
f39e17857e
Add a WebsocketService base class to retry, ensure that retries reset after a successful connection, update Cartesia to use the new WebsocketService
2025-01-14 13:09:58 -05:00
Aleix Conchillo Flaqué
5b632de04a
Merge pull request #982 from pipecat-ai/aleix/pipelinetask-cleanup-sink
...
pipeline(task): cleanup Sink processor
2025-01-14 09:14:03 -08:00
Mark Backman
bc839492b6
Add support for DeepSeek LLM
2025-01-14 09:34:33 -05:00
Mark Backman
8c0ecb89de
Refactor for new on_context_updated callback and new frame properties
2025-01-13 17:20:41 -05:00
Aleix Conchillo Flaqué
4c8fcb2cfc
pipeline(task): cleanup Sink processor
...
Fixes #953
2025-01-13 13:29:44 -08:00
Mark Backman
f1947d7d38
Update Anthropic and Gemini to allow overriding run_llm
2025-01-13 09:48:43 -05:00
Mark Backman
0852570212
Update Grok for function call override
2025-01-13 09:48:43 -05:00
Mark Backman
874b8bb136
Allow for an override of running a completion after a function call completes, OpenAI
2025-01-13 09:48:43 -05:00
Aleix Conchillo Flaqué
95e69597f3
update copyright keeping original year (2024)
2025-01-12 11:34:00 -08:00
