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

Merge pull request #2366 from pipecat-ai/aleix/run-bot-runner-arguments

Browse Source 
add sigint/sigterm to RunnerArguments
This commit is contained in:
Aleix Conchillo Flaqué
2025-08-05 14:46:19 -07:00
committed by GitHub
parent 2981afb117 66ad29b2b1
commit 6c6deb4e85
144 changed files with 437 additions and 424 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
CHANGELOG.md
View File

@@ -9,6 +9,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
### Added ### Added
- Added new `handle_sigint` and `handle_sigterm` to `RunnerArguments`. This
allows applications to know what settings they should use for the environment
they are running on.
- Added `processor` field to `ErrorFrame` to indicate `FrameProcessor` that - Added `processor` field to `ErrorFrame` to indicate `FrameProcessor` that
generated the error. generated the error.

6
examples/foundational/01-say-one-thing-piper.py
View File

@@ -34,7 +34,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
# Create an HTTP session # Create an HTTP session
@@ -50,7 +50,7 @@ async def run_bot(transport: BaseTransport):
async def on_client_connected(transport, client): async def on_client_connected(transport, client):
await task.queue_frames([TTSSpeakFrame(f"Hello there!"), EndFrame()]) await task.queue_frames([TTSSpeakFrame(f"Hello there!"), EndFrame()])
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -58,7 +58,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/01-say-one-thing-rime.py
View File

@@ -33,7 +33,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
# Create an HTTP session # Create an HTTP session
@@ -51,7 +51,7 @@ async def run_bot(transport: BaseTransport):
async def on_client_connected(transport, client): async def on_client_connected(transport, client):
await task.queue_frames([TTSSpeakFrame(f"Hello there!"), EndFrame()]) await task.queue_frames([TTSSpeakFrame(f"Hello there!"), EndFrame()])
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -59,7 +59,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/01-say-one-thing.py
View File

@@ -33,7 +33,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
tts = CartesiaTTSService( tts = CartesiaTTSService(
@@ -48,7 +48,7 @@ async def run_bot(transport: BaseTransport):
async def on_client_connected(transport, client): async def on_client_connected(transport, client):
await task.queue_frames([TTSSpeakFrame(f"Hello there!"), EndFrame()]) await task.queue_frames([TTSSpeakFrame(f"Hello there!"), EndFrame()])
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -56,7 +56,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/01c-fastpitch.py
View File

@@ -33,7 +33,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
tts = FastPitchTTSService(api_key=os.getenv("NVIDIA_API_KEY")) tts = FastPitchTTSService(api_key=os.getenv("NVIDIA_API_KEY"))
@@ -45,7 +45,7 @@ async def run_bot(transport: BaseTransport):
async def on_client_connected(transport, client): async def on_client_connected(transport, client):
await task.queue_frames([TTSSpeakFrame(f"Hello there!"), EndFrame()]) await task.queue_frames([TTSSpeakFrame(f"Hello there!"), EndFrame()])
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -53,7 +53,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/02-llm-say-one-thing.py
View File

@@ -34,7 +34,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
tts = CartesiaTTSService( tts = CartesiaTTSService(
@@ -58,7 +58,7 @@ async def run_bot(transport: BaseTransport):
async def on_client_connected(transport, client): async def on_client_connected(transport, client):
await task.queue_frames([LLMMessagesFrame(messages), EndFrame()]) await task.queue_frames([LLMMessagesFrame(messages), EndFrame()])
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -66,7 +66,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/03-still-frame.py
View File

@@ -40,7 +40,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
# Create an HTTP session # Create an HTTP session
@@ -63,7 +63,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -71,7 +71,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/03b-still-frame-imagen.py
View File

@@ -39,7 +39,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
imagegen = GoogleImageGenService( imagegen = GoogleImageGenService(
@@ -66,7 +66,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -74,7 +74,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

2
examples/foundational/04-transports-small-webrtc.py
View File

@@ -110,7 +110,7 @@ async def run_example(webrtc_connection: SmallWebRTCConnection):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)

6
examples/foundational/05-sync-speech-and-image.py
View File

@@ -83,7 +83,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
"""Run the Calendar Month Narration bot using WebRTC transport. """Run the Calendar Month Narration bot using WebRTC transport.
Args: Args:
@@ -170,14 +170,14 @@ async def run_bot(transport: BaseTransport):
await task.cancel() await task.cancel()
# Run the pipeline # Run the pipeline
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/06-listen-and-respond.py
View File

@@ -76,7 +76,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -133,14 +133,14 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/06a-image-sync.py
View File

@@ -91,7 +91,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -150,14 +150,14 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07-interruptible-cartesia-http.py
View File

@@ -48,7 +48,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -102,7 +102,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -110,7 +110,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07-interruptible.py
View File

@@ -47,7 +47,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -101,7 +101,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -109,7 +109,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07a-interruptible-speechmatics-vad.py
View File

@@ -48,7 +48,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
"""Speechmatics STT Service Example """Speechmatics STT Service Example
This example demonstrates using Speechmatics Speech-to-Text service with speaker diarization and intelligent speaker management. Key features: This example demonstrates using Speechmatics Speech-to-Text service with speaker diarization and intelligent speaker management. Key features:
@@ -160,7 +160,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -168,7 +168,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07a-interruptible-speechmatics.py
View File

@@ -52,7 +52,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
"""Run example using Speechmatics STT. """Run example using Speechmatics STT.
This example will use diarization within our STT service and output the words spoken by This example will use diarization within our STT service and output the words spoken by
@@ -143,7 +143,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -151,7 +151,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07aa-interruptible-soniox.py
View File

@@ -45,7 +45,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = SonioxSTTService( stt = SonioxSTTService(
@@ -100,7 +100,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -108,7 +108,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07ab-interruptible-inworld-http.py
View File

@@ -49,7 +49,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
# Create an HTTP session # Create an HTTP session
@@ -115,7 +115,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -123,7 +123,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07ac-interruptible-asyncai-http.py
View File

@@ -50,7 +50,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
# Create an HTTP session # Create an HTTP session
@@ -107,7 +107,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -115,7 +115,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07ac-interruptible-asyncai.py
View File

@@ -49,7 +49,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -103,7 +103,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -111,7 +111,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07b-interruptible-langchain.py
View File

@@ -67,7 +67,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -135,7 +135,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -143,7 +143,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07c-interruptible-deepgram-vad.py
View File

@@ -52,7 +52,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService( stt = DeepgramSTTService(
@@ -114,7 +114,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -122,7 +122,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07c-interruptible-deepgram.py
View File

@@ -49,7 +49,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -100,7 +100,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -108,7 +108,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07d-interruptible-elevenlabs-http.py
View File

@@ -50,7 +50,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
# Create an HTTP session # Create an HTTP session
@@ -107,7 +107,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -115,7 +115,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07d-interruptible-elevenlabs.py
View File

@@ -49,7 +49,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -103,7 +103,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -111,7 +111,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07e-interruptible-playht-http.py
View File

@@ -48,7 +48,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -103,7 +103,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -111,7 +111,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07e-interruptible-playht.py
View File

@@ -49,7 +49,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -105,7 +105,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -113,7 +113,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07f-interruptible-azure.py
View File

@@ -48,7 +48,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = AzureSTTService( stt = AzureSTTService(
@@ -109,7 +109,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -117,7 +117,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07g-interruptible-openai.py
View File

@@ -48,7 +48,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = OpenAISTTService( stt = OpenAISTTService(
@@ -104,7 +104,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -112,7 +112,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07h-interruptible-openpipe.py
View File

@@ -49,7 +49,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -108,7 +108,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -116,7 +116,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07i-interruptible-xtts.py
View File

@@ -49,7 +49,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
# Create an HTTP session # Create an HTTP session
@@ -106,7 +106,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -114,7 +114,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07j-interruptible-gladia.py
View File

@@ -50,7 +50,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = GladiaSTTService( stt = GladiaSTTService(
@@ -111,14 +111,14 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07k-interruptible-lmnt.py
View File

@@ -48,7 +48,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -99,7 +99,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -107,7 +107,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07l-interruptible-groq.py
View File

@@ -49,7 +49,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = GroqSTTService(api_key=os.getenv("GROQ_API_KEY")) stt = GroqSTTService(api_key=os.getenv("GROQ_API_KEY"))
@@ -104,7 +104,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -112,7 +112,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07m-interruptible-aws.py
View File

@@ -46,7 +46,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = AWSTranscribeSTTService() stt = AWSTranscribeSTTService()
@@ -105,7 +105,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -113,7 +113,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07n-interruptible-google.py
View File

@@ -49,7 +49,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = GoogleSTTService( stt = GoogleSTTService(
@@ -112,7 +112,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -120,7 +120,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07o-interruptible-assemblyai.py
View File

@@ -49,7 +49,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = AssemblyAISTTService( stt = AssemblyAISTTService(
@@ -105,7 +105,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -113,7 +113,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07p-interruptible-krisp.py
View File

@@ -52,7 +52,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -103,7 +103,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -111,7 +111,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07q-interruptible-rime-http.py
View File

@@ -50,7 +50,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
# Create an HTTP session # Create an HTTP session
@@ -108,7 +108,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -116,7 +116,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07q-interruptible-rime.py
View File

@@ -48,7 +48,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -102,7 +102,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -110,7 +110,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07r-interruptible-riva-nim.py
View File

@@ -48,7 +48,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = RivaSTTService(api_key=os.getenv("NVIDIA_API_KEY")) stt = RivaSTTService(api_key=os.getenv("NVIDIA_API_KEY"))
@@ -99,7 +99,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -107,7 +107,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07s-interruptible-google-audio-in.py
View File

@@ -213,7 +213,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
llm = GoogleLLMService( llm = GoogleLLMService(
@@ -280,7 +280,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -288,7 +288,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07t-interruptible-fish.py
View File

@@ -49,7 +49,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -103,7 +103,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -111,7 +111,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07u-interruptible-ultravox.py
View File

@@ -59,7 +59,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
tts = CartesiaTTSService( tts = CartesiaTTSService(
@@ -93,7 +93,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -101,7 +101,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07v-interruptible-neuphonic-http.py
View File

@@ -50,7 +50,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
# Create an HTTP session # Create an HTTP session
@@ -107,7 +107,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -115,7 +115,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07v-interruptible-neuphonic.py
View File

@@ -48,7 +48,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -102,7 +102,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -110,7 +110,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07w-interruptible-fal.py
View File

@@ -49,7 +49,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = FalSTTService( stt = FalSTTService(
@@ -105,7 +105,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -113,7 +113,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07y-interruptible-minimax.py
View File

@@ -51,7 +51,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
# Create an HTTP session # Create an HTTP session
@@ -109,7 +109,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -117,7 +117,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/07z-interruptible-sarvam.py
View File

@@ -51,7 +51,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
# Create an HTTP session # Create an HTTP session
@@ -108,7 +108,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -116,7 +116,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/09-mirror.py
View File

@@ -72,7 +72,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
pipeline = Pipeline([transport.input(), MirrorProcessor(), transport.output()]) pipeline = Pipeline([transport.input(), MirrorProcessor(), transport.output()])
@@ -91,7 +91,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -99,7 +99,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/09a-local-mirror.py
View File

@@ -75,7 +75,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
tk_root = tk.Tk() tk_root = tk.Tk()
@@ -115,7 +115,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await asyncio.gather(runner.run(task), run_tk()) await asyncio.gather(runner.run(task), run_tk())
@@ -123,7 +123,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/10-wake-phrase.py
View File

@@ -49,7 +49,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -105,7 +105,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -113,7 +113,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/11-sound-effects.py
View File

@@ -101,7 +101,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -157,7 +157,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -165,7 +165,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/12-describe-video.py
View File

@@ -70,7 +70,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
user_response = UserResponseAggregator() user_response = UserResponseAggregator()
@@ -123,7 +123,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -131,7 +131,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/12a-describe-video-gemini-flash.py
View File

@@ -70,7 +70,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
user_response = UserResponseAggregator() user_response = UserResponseAggregator()
@@ -129,7 +129,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -137,7 +137,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/12b-describe-video-gpt-4o.py
View File

@@ -70,7 +70,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
user_response = UserResponseAggregator() user_response = UserResponseAggregator()
@@ -129,7 +129,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -137,7 +137,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/12c-describe-video-anthropic.py
View File

@@ -70,7 +70,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
user_response = UserResponseAggregator() user_response = UserResponseAggregator()
@@ -129,7 +129,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -137,7 +137,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/13-whisper-transcription.py
View File

@@ -51,7 +51,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = WhisperSTTService() stt = WhisperSTTService()
@@ -67,7 +67,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -75,7 +75,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/13b-deepgram-transcription.py
View File

@@ -42,7 +42,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService( stt = DeepgramSTTService(
@@ -61,7 +61,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -69,7 +69,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/13c-gladia-transcription.py
View File

@@ -42,7 +42,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = GladiaSTTService( stt = GladiaSTTService(
@@ -61,7 +61,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -69,7 +69,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/13c-gladia-translation.py
View File

@@ -51,7 +51,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = GladiaSTTService( stt = GladiaSTTService(
@@ -82,7 +82,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -90,7 +90,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/13d-assemblyai-transcription.py
View File

@@ -42,7 +42,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = AssemblyAISTTService( stt = AssemblyAISTTService(
@@ -60,7 +60,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -68,7 +68,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/13e-whisper-mlx.py
View File

@@ -72,7 +72,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = WhisperSTTServiceMLX(model=MLXModel.LARGE_V3_TURBO) stt = WhisperSTTServiceMLX(model=MLXModel.LARGE_V3_TURBO)
@@ -94,7 +94,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -102,7 +102,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/13f-cartesia-transcription.py
View File

@@ -42,7 +42,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = CartesiaSTTService( stt = CartesiaSTTService(
@@ -61,7 +61,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -69,7 +69,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/13g-sambanova-transcription.py
View File

@@ -73,7 +73,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = SambaNovaSTTService( stt = SambaNovaSTTService(
@@ -98,7 +98,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -106,7 +106,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/13h-speechmatics-transcription.py
View File

@@ -43,7 +43,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
"""Run example using Speechmatics STT. """Run example using Speechmatics STT.
This example will use diarization within our STT service and output the words spoken by This example will use diarization within our STT service and output the words spoken by
@@ -81,7 +81,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -89,7 +89,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/13i-soniox-transcription.py
View File

@@ -49,7 +49,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = SonioxSTTService( stt = SonioxSTTService(
@@ -67,7 +67,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -75,7 +75,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14-function-calling.py
View File

@@ -60,7 +60,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -151,7 +151,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -159,7 +159,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14a-function-calling-anthropic.py
View File

@@ -61,7 +61,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -145,7 +145,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -153,7 +153,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14b-function-calling-anthropic-video.py
View File

@@ -83,7 +83,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -199,7 +199,7 @@ If you need to use a tool, simply use the tool. Do not tell the user the tool yo
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -207,7 +207,7 @@ If you need to use a tool, simply use the tool. Do not tell the user the tool yo
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14c-function-calling-together.py
View File

@@ -57,7 +57,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -137,7 +137,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -145,7 +145,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14d-function-calling-video.py
View File

@@ -83,7 +83,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -188,7 +188,7 @@ indicate you should use the get_image tool are:
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -196,7 +196,7 @@ indicate you should use the get_image tool are:
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14e-function-calling-google.py
View File

@@ -88,7 +88,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -210,7 +210,7 @@ indicate you should use the get_image tool are:
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -218,7 +218,7 @@ indicate you should use the get_image tool are:
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14f-function-calling-groq.py
View File

@@ -58,7 +58,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = GroqSTTService(api_key=os.getenv("GROQ_API_KEY"), model="distil-whisper-large-v3-en") stt = GroqSTTService(api_key=os.getenv("GROQ_API_KEY"), model="distil-whisper-large-v3-en")
@@ -139,7 +139,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -147,7 +147,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14g-function-calling-grok.py
View File

@@ -56,7 +56,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -129,7 +129,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -137,7 +137,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14h-function-calling-azure.py
View File

@@ -57,7 +57,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -138,7 +138,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -146,7 +146,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14i-function-calling-fireworks.py
View File

@@ -57,7 +57,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -137,7 +137,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -145,7 +145,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14j-function-calling-nim.py
View File

@@ -57,7 +57,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -135,7 +135,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -143,7 +143,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14k-function-calling-cerebras.py
View File

@@ -57,7 +57,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -144,7 +144,7 @@ Start by asking me for my location. Then, use 'get_weather_current' to give me a
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -152,7 +152,7 @@ Start by asking me for my location. Then, use 'get_weather_current' to give me a
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14l-function-calling-deepseek.py
View File

@@ -57,7 +57,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -144,7 +144,7 @@ Start by asking me for my location. Then, use 'get_weather_current' to give me a
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -152,7 +152,7 @@ Start by asking me for my location. Then, use 'get_weather_current' to give me a
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14m-function-calling-openrouter.py
View File

@@ -57,7 +57,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -138,7 +138,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -146,7 +146,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14n-function-calling-perplexity.py
View File

@@ -54,7 +54,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -107,7 +107,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -115,7 +115,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14o-function-calling-gemini-openai-format.py
View File

@@ -57,7 +57,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -134,7 +134,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -142,7 +142,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14p-function-calling-gemini-vertex-ai.py
View File

@@ -57,7 +57,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -140,7 +140,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -148,7 +148,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14q-function-calling-qwen.py
View File

@@ -57,7 +57,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -136,7 +136,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -144,7 +144,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14r-function-calling-aws.py
View File

@@ -58,7 +58,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = AWSTranscribeSTTService() stt = AWSTranscribeSTTService()
@@ -151,7 +151,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -159,7 +159,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14s-function-calling-sambanova.py
View File

@@ -58,7 +58,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = SambaNovaSTTService( stt = SambaNovaSTTService(
@@ -143,7 +143,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -151,7 +151,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14t-function-calling-direct.py
View File

@@ -73,7 +73,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -137,7 +137,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -145,7 +145,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/14u-function-calling-ollama.py
View File

@@ -62,7 +62,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -153,7 +153,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -161,7 +161,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/15-switch-voices.py
View File

@@ -78,7 +78,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -174,7 +174,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -182,7 +182,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/15a-switch-languages.py
View File

@@ -73,7 +73,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService( stt = DeepgramSTTService(
@@ -162,7 +162,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -170,7 +170,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/16-gpu-container-local-bot.py
View File

@@ -48,7 +48,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -139,7 +139,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -147,7 +147,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/17-detect-user-idle.py
View File

@@ -50,7 +50,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -136,7 +136,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -144,7 +144,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/18-gstreamer-filesrc.py
View File

@@ -45,7 +45,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport, args: argparse.Namespace): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot with video input: {args.input}") logger.info(f"Starting bot with video input: {args.input}")
gst = GStreamerPipelineSource( gst = GStreamerPipelineSource(
@@ -65,7 +65,7 @@ async def run_bot(transport: BaseTransport, args: argparse.Namespace):
task = PipelineTask(pipeline) task = PipelineTask(pipeline)
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -73,7 +73,7 @@ async def run_bot(transport: BaseTransport, args: argparse.Namespace):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/18a-gstreamer-videotestsrc.py
View File

@@ -38,7 +38,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot with video test source") logger.info(f"Starting bot with video test source")
gst = GStreamerPipelineSource( gst = GStreamerPipelineSource(
@@ -57,7 +57,7 @@ async def run_bot(transport: BaseTransport):
task = PipelineTask(pipeline) task = PipelineTask(pipeline)
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -65,7 +65,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/19-openai-realtime-beta.py
View File

@@ -108,7 +108,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
session_properties = SessionProperties( session_properties = SessionProperties(
@@ -213,7 +213,7 @@ Remember, your responses should be short. Just one or two sentences, usually."""
line = f"{timestamp}{msg.role}: {msg.content}" line = f"{timestamp}{msg.role}: {msg.content}"
logger.info(f"Transcript: {line}") logger.info(f"Transcript: {line}")
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -221,7 +221,7 @@ Remember, your responses should be short. Just one or two sentences, usually."""
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/19a-azure-realtime-beta.py
View File

@@ -105,7 +105,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
session_properties = SessionProperties( session_properties = SessionProperties(
@@ -197,7 +197,7 @@ Remember, your responses should be short. Just one or two sentences, usually."""
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -205,7 +205,7 @@ Remember, your responses should be short. Just one or two sentences, usually."""
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/20a-persistent-context-openai.py
View File

@@ -187,7 +187,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
global tts global tts
@@ -240,7 +240,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -248,7 +248,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/20b-persistent-context-openai-realtime.py
View File

@@ -175,7 +175,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY")) stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
@@ -250,7 +250,7 @@ Remember, your responses should be short. Just one or two sentences, usually."""
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -258,7 +258,7 @@ Remember, your responses should be short. Just one or two sentences, usually."""
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

6
examples/foundational/20c-persistent-context-anthropic.py
View File

@@ -182,7 +182,7 @@ transport_params = {
} }
async def run_bot(transport: BaseTransport): async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
logger.info(f"Starting bot") logger.info(f"Starting bot")
global tts global tts
@@ -239,7 +239,7 @@ async def run_bot(transport: BaseTransport):
logger.info(f"Client disconnected") logger.info(f"Client disconnected")
await task.cancel() await task.cancel()
runner = PipelineRunner(handle_sigint=False) runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
await runner.run(task) await runner.run(task)
@@ -247,7 +247,7 @@ async def run_bot(transport: BaseTransport):
async def bot(runner_args: RunnerArguments): async def bot(runner_args: RunnerArguments):
"""Main bot entry point compatible with Pipecat Cloud.""" """Main bot entry point compatible with Pipecat Cloud."""
transport = await create_transport(runner_args, transport_params) transport = await create_transport(runner_args, transport_params)
await run_bot(transport) await run_bot(transport, runner_args)
if __name__ == "__main__": if __name__ == "__main__":

Some files were not shown because too many files have changed in this diff Show More