ai_service: use openai.realtime.events instead of openai_realtime_beta.events
This commit is contained in:
@@ -97,9 +97,7 @@ class AIService(FrameProcessor):
|
|||||||
pass
|
pass
|
||||||
|
|
||||||
async def _update_settings(self, settings: Mapping[str, Any]):
|
async def _update_settings(self, settings: Mapping[str, Any]):
|
||||||
from pipecat.services.openai_realtime_beta.events import (
|
from pipecat.services.openai.realtime.events import SessionProperties
|
||||||
SessionProperties,
|
|
||||||
)
|
|
||||||
|
|
||||||
for key, value in settings.items():
|
for key, value in settings.items():
|
||||||
logger.debug("Update request for:", key, value)
|
logger.debug("Update request for:", key, value)
|
||||||
@@ -111,9 +109,7 @@ class AIService(FrameProcessor):
|
|||||||
logger.debug("Attempting to update", key, value)
|
logger.debug("Attempting to update", key, value)
|
||||||
|
|
||||||
try:
|
try:
|
||||||
from pipecat.services.openai_realtime_beta.events import (
|
from pipecat.services.openai.realtime.events import TurnDetection
|
||||||
TurnDetection,
|
|
||||||
)
|
|
||||||
|
|
||||||
if isinstance(self._session_properties, SessionProperties):
|
if isinstance(self._session_properties, SessionProperties):
|
||||||
current_properties = self._session_properties
|
current_properties = self._session_properties
|
||||||
|
|||||||
Reference in New Issue
Block a user