f5c4ab50f4
* auto fixes * auto fix pt2 and transitive deps and undefined var checking locals() * manual fixes (ignored or letta-code fixed) * fix circular import * remove all ignores, add FastAPI rules and Ruff rules * add ty and precommit * ruff stuff * ty check fixes * ty check fixes pt 2 * error on invalid
64 lines
2.5 KiB
Python
64 lines
2.5 KiB
Python
from urllib.parse import urljoin
|
|
|
|
from letta.local_llm.settings.settings import get_completions_settings
|
|
from letta.local_llm.utils import post_json_auth_request
|
|
|
|
KOBOLDCPP_API_SUFFIX = "/api/v1/generate"
|
|
|
|
|
|
def get_koboldcpp_completion(endpoint, auth_type, auth_key, prompt, context_window, grammar=None):
|
|
"""See https://lite.koboldai.net/koboldcpp_api for API spec"""
|
|
from letta.utils import printd
|
|
|
|
# Approximate token count: bytes / 4
|
|
prompt_tokens = len(prompt.encode("utf-8")) // 4
|
|
if prompt_tokens > context_window:
|
|
raise Exception(f"Request exceeds maximum context length ({prompt_tokens} > {context_window} tokens)")
|
|
|
|
# Settings for the generation, includes the prompt + stop tokens, max length, etc
|
|
settings = get_completions_settings()
|
|
request = settings
|
|
request["prompt"] = prompt
|
|
request["max_context_length"] = context_window
|
|
request["max_length"] = 400 # if we don't set this, it'll default to 100 which is quite short
|
|
|
|
# Set grammar
|
|
if grammar is not None:
|
|
request["grammar"] = grammar
|
|
|
|
if not endpoint.startswith(("http://", "https://")):
|
|
raise ValueError(f"Provided OPENAI_API_BASE value ({endpoint}) must begin with http:// or https://")
|
|
|
|
try:
|
|
# NOTE: llama.cpp server returns the following when it's out of context
|
|
# curl: (52) Empty reply from server
|
|
URI = urljoin(endpoint.strip("/") + "/", KOBOLDCPP_API_SUFFIX.strip("/"))
|
|
response = post_json_auth_request(uri=URI, json_payload=request, auth_type=auth_type, auth_key=auth_key)
|
|
if response.status_code == 200:
|
|
result_full = response.json()
|
|
printd(f"JSON API response:\n{result_full}")
|
|
result = result_full["results"][0]["text"]
|
|
else:
|
|
raise Exception(
|
|
f"API call got non-200 response code (code={response.status_code}, msg={response.text}) for address: {URI}."
|
|
+ f" Make sure that the koboldcpp server is running and reachable at {URI}."
|
|
)
|
|
|
|
except:
|
|
# TODO handle gracefully
|
|
raise
|
|
|
|
# Pass usage statistics back to main thread
|
|
# These are used to compute memory warning messages
|
|
# KoboldCpp doesn't return anything?
|
|
# https://lite.koboldai.net/koboldcpp_api#/v1/post_v1_generate
|
|
completion_tokens = None
|
|
total_tokens = prompt_tokens + completion_tokens if completion_tokens is not None else None
|
|
usage = {
|
|
"prompt_tokens": prompt_tokens,
|
|
"completion_tokens": completion_tokens,
|
|
"total_tokens": total_tokens,
|
|
}
|
|
|
|
return result, usage
|