removing reserved words var names
This commit is contained in:
parent
0c353939d9
commit
175f035d86
1 changed files with 4 additions and 4 deletions
|
|
@ -386,7 +386,7 @@ async def proxy(request: Request):
|
||||||
stream = payload.get("stream")
|
stream = payload.get("stream")
|
||||||
think = payload.get("think")
|
think = payload.get("think")
|
||||||
raw = payload.get("raw")
|
raw = payload.get("raw")
|
||||||
format = payload.get("format")
|
_format = payload.get("format")
|
||||||
images = payload.get("images")
|
images = payload.get("images")
|
||||||
options = payload.get("options")
|
options = payload.get("options")
|
||||||
keep_alive = payload.get("keep_alive")
|
keep_alive = payload.get("keep_alive")
|
||||||
|
|
@ -414,7 +414,7 @@ async def proxy(request: Request):
|
||||||
# 4. Async generator that streams data and decrements the counter
|
# 4. Async generator that streams data and decrements the counter
|
||||||
async def stream_generate_response():
|
async def stream_generate_response():
|
||||||
try:
|
try:
|
||||||
async_gen = await client.generate(model=model, prompt=prompt, suffix=suffix, system=system, template=template, context=context, stream=stream, think=think, raw=raw, format=format, images=images, options=options, keep_alive=keep_alive)
|
async_gen = await client.generate(model=model, prompt=prompt, suffix=suffix, system=system, template=template, context=context, stream=stream, think=think, raw=raw, format=_format, images=images, options=options, keep_alive=keep_alive)
|
||||||
if stream == True:
|
if stream == True:
|
||||||
async for chunk in async_gen:
|
async for chunk in async_gen:
|
||||||
if hasattr(chunk, "model_dump_json"):
|
if hasattr(chunk, "model_dump_json"):
|
||||||
|
|
@ -974,8 +974,8 @@ async def config_proxy(request: Request):
|
||||||
return {"url": url, "status": "ok", "version": "latest"}
|
return {"url": url, "status": "ok", "version": "latest"}
|
||||||
else:
|
else:
|
||||||
return {"url": url, "status": "ok", "version": data.get("version")}
|
return {"url": url, "status": "ok", "version": data.get("version")}
|
||||||
except Exception as exc:
|
except Exception as e:
|
||||||
return {"url": url, "status": "error", "detail": str(exc)}
|
return {"url": url, "status": "error", "detail": str(e)}
|
||||||
|
|
||||||
results = await asyncio.gather(*[check_endpoint(ep) for ep in config.endpoints])
|
results = await asyncio.gather(*[check_endpoint(ep) for ep in config.endpoints])
|
||||||
return {"endpoints": results}
|
return {"endpoints": results}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue