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

processors(rtvi): process options in the order they are defined

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-08-14 22:26:49 -07:00
parent d5c7b28cad
commit 61ac83e2d9
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/pipecat/processors/frameworks/rtvi.py
View File

@@ -498,10 +498,14 @@ class RTVIProcessor(FrameProcessor):
async def _update_service_config(self, config: RTVIServiceConfig):
service = self._registered_services[config.service]
for option in config.options:
handler = service._options_dict[option.name].handler
await handler(self, service.name, option)
self._update_config_option(service.name, option)
# Process options in the order they are defined, not in the order they
# are sent.
for option_def in service.options:
for option in config.options:
if option_def.name == option.name:
handler = option_def.handler
await handler(self, service.name, option)
self._update_config_option(service.name, option)
async def _update_config(self, data: RTVIConfig):
for service_config in data.config: