apunkt/MetaGPT
1
0
Fork 0
mirror of https://github.com/FoundationAgents/MetaGPT.git synced 2026-04-25 00:36:55 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix embedding output

Browse source
This commit is contained in:
EvensXia 2024-10-30 09:55:13 +08:00
parent 062b13fc6c
commit 2bca5c9d06
1 changed files with 10 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

12
metagpt/provider/ollama_api.py
View file

@ -49,7 +49,7 @@ class OllamaMessageBase:
if tpe == "text":
return msg["text"], None
elif tpe == "image_url":
return None, msg["image_url"]["url"][self._image_b64_rms:]
return None, msg["image_url"]["url"][self._image_b64_rms :]
else:
raise ValueError
else:
@ -300,6 +300,10 @@ class OllamaEmbeddings(OllamaLLM):
def _llama_api_kwargs(self) -> dict:
return {"options": {"temperature": 0.3}}
@property
def _llama_embedding_key(self) -> str:
return "embedding"
async def _achat_completion(self, messages: list[dict], timeout: int = USE_CONFIG_TIMEOUT) -> dict:
resp, _, _ = await self.client.arequest(
method=self.http_method,
@ -307,7 +311,7 @@ class OllamaEmbeddings(OllamaLLM):
params=self.ollama_message.apply(messages=messages),
request_timeout=self.get_timeout(timeout),
)
return self.ollama_message.decode(resp)["embedding"]
return self.ollama_message.decode(resp)[self._llama_embedding_key]
async def _achat_completion_stream(self, messages: list[dict], timeout: int = USE_CONFIG_TIMEOUT) -> str:
return await self._achat_completion(messages, timeout=self.get_timeout(timeout))
@ -321,3 +325,7 @@ class OllamaEmbed(OllamaEmbeddings):
@property
def _llama_api_inuse(self) -> OllamaMessageAPI:
return OllamaMessageAPI.EMBED
@property
def _llama_embedding_key(self) -> str:
return "embeddings"