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

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

Browse Source 
This reverts commit 61ac83e2d9.
This commit is contained in:
Aleix Conchillo Flaqué
2024-08-15 11:51:00 -07:00
parent 8670b2d994
commit 5be6422cc8
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -521,14 +521,10 @@ class RTVIProcessor(FrameProcessor):
async def _update_service_config(self, config: RTVIServiceConfig):
service = self._registered_services[config.service]
# 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)
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)
async def _update_config(self, data: RTVIConfig):
for service_config in data.config: