|
8 | 8 | from typing import Any |
9 | 9 |
|
10 | 10 | from loguru import logger |
11 | | -from pipecat.frames.frames import TTSSpeakFrame |
12 | 11 | from pipecat.services.llm_service import FunctionCallParams, FunctionCallResultProperties |
13 | 12 |
|
14 | 13 | from .hub_bridge import ( |
@@ -214,21 +213,6 @@ async def _send_tool_result( |
214 | 213 | ) |
215 | 214 |
|
216 | 215 |
|
217 | | -async def speak_tool_progress(params: FunctionCallParams, text: str) -> None: |
218 | | - try: |
219 | | - await params.llm.push_frame(TTSSpeakFrame(text)) |
220 | | - except Exception: |
221 | | - logger.exception("iris.voice.tool.progress_speech_failed name={}", params.function_name) |
222 | | - |
223 | | - |
224 | | -def hub_progress_text(action: str) -> str: |
225 | | - if action == "interrupt": |
226 | | - return "Stopping the computer now." |
227 | | - if action == "status": |
228 | | - return "Checking the computer now." |
229 | | - return "I'm on it." |
230 | | - |
231 | | - |
232 | 216 | def hub_result_status(result: Any) -> str | None: |
233 | 217 | if not isinstance(result, dict): |
234 | 218 | return None |
@@ -703,9 +687,6 @@ async def hub(params: FunctionCallParams) -> None: |
703 | 687 | "hubId": hub_id, |
704 | 688 | "threadId": thread_id, |
705 | 689 | }) |
706 | | - progress_text = hub_progress_text(action) |
707 | | - events.emit({"type": "assistant.text", "text": progress_text}) |
708 | | - await speak_tool_progress(params, progress_text) |
709 | 690 | await _send_tool_result( |
710 | 691 | params, |
711 | 692 | { |
@@ -766,7 +747,6 @@ async def hub(params: FunctionCallParams) -> None: |
766 | 747 | if action in {"start", "steer"} and status in RUNNING_HUB_STATUSES: |
767 | 748 | final_result["voice"] = { |
768 | 749 | "state": "running", |
769 | | - "progressAlreadySpoken": progress_text, |
770 | 750 | "completionExpected": True, |
771 | 751 | } |
772 | 752 | await _send_tool_result( |
|
0 commit comments