diff --git a/comps/cores/mega/orchestrator.py b/comps/cores/mega/orchestrator.py index 2410140b8..94ff5c330 100644 --- a/comps/cores/mega/orchestrator.py +++ b/comps/cores/mega/orchestrator.py @@ -136,7 +136,10 @@ async def execute( # send the cur_node request/reply endpoint = self.services[cur_node].endpoint_path llm_parameters_dict = llm_parameters.dict() - if self.services[cur_node].service_type == ServiceType.LLM: + if ( + self.services[cur_node].service_type == ServiceType.LLM + or self.services[cur_node].service_type == ServiceType.LVM + ): for field, value in llm_parameters_dict.items(): if inputs.get(field) != value: inputs[field] = value