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

Development runner: handle_sigint defaults to False

Browse Source
This commit is contained in:
Mark Backman
2025-08-11 22:06:56 -04:00
parent 0d499a8aa3
commit cd5a3c13bd
2 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/pipecat/runner/run.py
View File

@@ -145,7 +145,6 @@ async def _run_telephony_bot(websocket: WebSocket):
# Just pass the WebSocket - let the bot handle parsing # Just pass the WebSocket - let the bot handle parsing
runner_args = WebSocketRunnerArguments(websocket=websocket) runner_args = WebSocketRunnerArguments(websocket=websocket)
runner_args.handle_sigint = False
await bot_module.bot(runner_args) await bot_module.bot(runner_args)
@@ -223,7 +222,6 @@ def _setup_webrtc_routes(app: FastAPI, esp32_mode: bool = False, host: str = "lo
bot_module = _get_bot_module() bot_module = _get_bot_module()
runner_args = SmallWebRTCRunnerArguments(webrtc_connection=pipecat_connection) runner_args = SmallWebRTCRunnerArguments(webrtc_connection=pipecat_connection)
runner_args.handle_sigint = False
background_tasks.add_task(bot_module.bot, runner_args) background_tasks.add_task(bot_module.bot, runner_args)
answer = pipecat_connection.get_answer() answer = pipecat_connection.get_answer()
@@ -266,7 +264,6 @@ def _setup_daily_routes(app: FastAPI):
# Start the bot in the background with empty body for GET requests # Start the bot in the background with empty body for GET requests
bot_module = _get_bot_module() bot_module = _get_bot_module()
runner_args = DailyRunnerArguments(room_url=room_url, token=token) runner_args = DailyRunnerArguments(room_url=room_url, token=token)
runner_args.handle_sigint = False
asyncio.create_task(bot_module.bot(runner_args)) asyncio.create_task(bot_module.bot(runner_args))
return RedirectResponse(room_url) return RedirectResponse(room_url)
@@ -311,7 +308,6 @@ def _setup_daily_routes(app: FastAPI):
# Start the bot in the background with extracted body data # Start the bot in the background with extracted body data
bot_module = _get_bot_module() bot_module = _get_bot_module()
runner_args = DailyRunnerArguments(room_url=room_url, token=token, body=bot_body) runner_args = DailyRunnerArguments(room_url=room_url, token=token, body=bot_body)
runner_args.handle_sigint = False
asyncio.create_task(bot_module.bot(runner_args)) asyncio.create_task(bot_module.bot(runner_args))
# Match PCC /start endpoint response format: # Match PCC /start endpoint response format:
return {"dailyRoom": room_url, "dailyToken": token} return {"dailyRoom": room_url, "dailyToken": token}

2
src/pipecat/runner/types.py
View File

@@ -25,7 +25,7 @@ class RunnerArguments:
pipeline_idle_timeout_secs: int = field(init=False) pipeline_idle_timeout_secs: int = field(init=False)
def __post_init__(self): def __post_init__(self):
self.handle_sigint = True self.handle_sigint = False
self.handle_sigterm = False self.handle_sigterm = False
self.pipeline_idle_timeout_secs = 300 self.pipeline_idle_timeout_secs = 300