bugfix
This commit is contained in:
parent
d8e086c8b1
commit
8520ea1d75
@ -1,7 +1,7 @@
|
|||||||
async def gen():
|
async def gen():
|
||||||
env = request._run_ns.copy()
|
env = request._run_ns.copy()
|
||||||
f = partial(inference_generator, request, *args, params_kw=params_kw, **kw)
|
f = partial(inference_generator, request, *args, params_kw=params_kw, **kw)
|
||||||
if params_kw.stream:
|
if params_kw.stream:
|
||||||
async for l in f():
|
async for l in f():
|
||||||
yield b'data: ' + l + b'\n'
|
yield b'data: ' + l + b'\n'
|
||||||
yield b'data: [DONE]'
|
yield b'data: [DONE]'
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user