UniqAI/open-webui
1
0
Fork 0
mirror of https://github.com/open-webui/open-webui synced 2025-04-15 04:53:10 +00:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

Added server side Prefixing

Browse Source
This commit is contained in:
jayteaftw 2025-02-05 14:03:16 -08:00
parent 7b8e5d4e7c
commit 6d2f87e904
2 changed files with 24 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
backend/open_webui/config.py
View File

@ -1339,7 +1339,7 @@ RAG_EMBEDDING_PASSAGE_PREFIX = (
) )
RAG_EMBEDDING_PREFIX_FIELD_NAME = ( RAG_EMBEDDING_PREFIX_FIELD_NAME = (
os.environ.get("RAG_EMBEDDING_PREFIX_FIELD_NAME", "input_type") os.environ.get("RAG_EMBEDDING_PREFIX_FIELD_NAME", None)
) )
RAG_RERANKING_MODEL = PersistentConfig( RAG_RERANKING_MODEL = PersistentConfig(

25
backend/open_webui/retrieval/utils.py
View File

@ -418,14 +418,22 @@ def get_model_path(model: str, update_model: bool = False):
def generate_openai_batch_embeddings( def generate_openai_batch_embeddings(
model: str, texts: list[str], url: str = "https://api.openai.com/v1", key: str = "", prefix: str = None model: str, texts: list[str], url: str = "https://api.openai.com/v1", key: str = "", prefix: str = None
) -> Optional[list[list[float]]]: ) -> Optional[list[list[float]]]:
try: try:
json_data = {
"input": texts,
"model": model
}
if isinstance(RAG_EMBEDDING_PREFIX_FIELD_NAME,str) and isinstance(prefix,str):
json_data[RAG_EMBEDDING_PREFIX_FIELD_NAME] = prefix
r = requests.post( r = requests.post(
f"{url}/embeddings", f"{url}/embeddings",
headers={ headers={
"Content-Type": "application/json", "Content-Type": "application/json",
"Authorization": f"Bearer {key}", "Authorization": f"Bearer {key}",
}, },
json={"input": texts, "model": model} if not prefix else {"input": texts, "model": model, RAG_EMBEDDING_PREFIX_FIELD_NAME: prefix}, json=json_data,
) )
r.raise_for_status() r.raise_for_status()
data = r.json() data = r.json()
@ -442,13 +450,20 @@ def generate_ollama_batch_embeddings(
model: str, texts: list[str], url: str, key: str = "", prefix: str = None model: str, texts: list[str], url: str, key: str = "", prefix: str = None
) -> Optional[list[list[float]]]: ) -> Optional[list[list[float]]]:
try: try:
json_data = {
"input": texts,
"model": model
}
if isinstance(RAG_EMBEDDING_PREFIX_FIELD_NAME,str) and isinstance(prefix,str):
json_data[RAG_EMBEDDING_PREFIX_FIELD_NAME] = prefix
r = requests.post( r = requests.post(
f"{url}/api/embed", f"{url}/api/embed",
headers={ headers={
"Content-Type": "application/json", "Content-Type": "application/json",
"Authorization": f"Bearer {key}", "Authorization": f"Bearer {key}",
}, },
json={"input": texts, "model": model} if not prefix else {"input": texts, "model": model, RAG_EMBEDDING_PREFIX_FIELD_NAME: prefix}, json=json_data,
) )
r.raise_for_status() r.raise_for_status()
data = r.json() data = r.json()
@ -466,6 +481,12 @@ def generate_embeddings(engine: str, model: str, text: Union[str, list[str]], pr
url = kwargs.get("url", "") url = kwargs.get("url", "")
key = kwargs.get("key", "") key = kwargs.get("key", "")
if prefix is not None and RAG_EMBEDDING_PREFIX_FIELD_NAME is None:
if isinstance(text, list):
text = [f'{prefix}{text_element}' for text_element in text]
else:
text = f'{prefix}{text}'
if engine == "ollama": if engine == "ollama":
if isinstance(text, list): if isinstance(text, list):
embeddings = generate_ollama_batch_embeddings( embeddings = generate_ollama_batch_embeddings(