huggingface/text-generation-inference
5
0
Fork 0
mirror of https://github.com/huggingface/text-generation-inference.git synced 2025-09-10 20:04:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update server.py

Browse Source
This commit is contained in:
Robert Shaw 2023-08-28 11:03:54 -04:00 committed by GitHub
parent 0b8f0ae068
commit bd5fcf6f13
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
deepsparse/server.py
View File

@ -11,7 +11,6 @@ from utils import GenerateRequestInputs, GenerateRequestOutputs, GenerateRequest
TOKENIZER_PATH = "/home/robertgshaw/.cache/sparsezoo/neuralmagic/codegen_mono-350m-bigpython_bigquery_thepile-base/deployment" TOKENIZER_PATH = "/home/robertgshaw/.cache/sparsezoo/neuralmagic/codegen_mono-350m-bigpython_bigquery_thepile-base/deployment"
MODEL_PATH = "/home/robertgshaw/.cache/sparsezoo/neuralmagic/codegen_mono-350m-bigpython_bigquery_thepile-base/model.onnx/model.onnx" MODEL_PATH = "/home/robertgshaw/.cache/sparsezoo/neuralmagic/codegen_mono-350m-bigpython_bigquery_thepile-base/model.onnx/model.onnx"
MESSAGE_STREAM_RETRY_TIMEOUT = 15000 # milisecond
artifacts = {} artifacts = {}
@ -52,38 +51,6 @@ def generate(inputs: GenerateRequestInputs) -> GenerateRequestOutputs:
gr_outputs.finish_reason = generation.finish_reason gr_outputs.finish_reason = generation.finish_reason
return gr_outputs return gr_outputs
@app.post("/generate_stream")
async def generate_stream(request: fastapi.Request, inputs: GenerateRequestInputs):
# convert input to generate request
generate_request = GenerateRequest.from_gr_inputs(inputs)
# submit request to the router
artifacts["router"].submit_request(generate_request)
async def token_generator():
while True:
if await request.is_disconnected():
break
generation = generate_request.response_stream.get()
if not generation.stopped:
yield {
"event": "token_generated",
"id": "message_id",
"retry": MESSAGE_STREAM_RETRY_TIMEOUT,
"data": generation.token
}
else:
yield {
"event": "token_generated",
"id": "message_id",
"retry": MESSAGE_STREAM_RETRY_TIMEOUT,
"data": generation.finish_reason
}
return EventSourceResponse(token_generator())
if __name__ == "__main__": if __name__ == "__main__":
uvicorn.run( uvicorn.run(
"server:app", "server:app",