Skip to content

Commit fb4b8d2

Browse files
Fix LVM streaming issue (#637)
* Fix LVM streaming issue Signed-off-by: lvliang-intel <[email protected]> * [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci --------- Signed-off-by: lvliang-intel <[email protected]> Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
1 parent 7e1a2e5 commit fb4b8d2

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

comps/cores/mega/orchestrator.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -136,7 +136,10 @@ async def execute(
136136
# send the cur_node request/reply
137137
endpoint = self.services[cur_node].endpoint_path
138138
llm_parameters_dict = llm_parameters.dict()
139-
if self.services[cur_node].service_type == ServiceType.LLM:
139+
if (
140+
self.services[cur_node].service_type == ServiceType.LLM
141+
or self.services[cur_node].service_type == ServiceType.LVM
142+
):
140143
for field, value in llm_parameters_dict.items():
141144
if inputs.get(field) != value:
142145
inputs[field] = value

0 commit comments

Comments
 (0)