bugfix
This commit is contained in:
parent
42b9ef177e
commit
6ba3b544c0
@ -1,5 +1,5 @@
|
||||
if params_kw.id:
|
||||
async with get_sql_context(request._run_ns, 'dagflow') as sor:
|
||||
async with get_sor_context(request._run_ns, 'dagflow') as sor:
|
||||
recs = await sor.R('flow_instance', {'id': params_kw.id})
|
||||
if recs:
|
||||
await flow_engines[0].step(recs[0])
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user