9 lines
271 B
Plaintext
9 lines
271 B
Plaintext
if params_kw.id:
|
|
async with get_sql_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])
|
|
return 'OK'
|
|
return 'Error'
|
|
return "please give me a id(flow_instance's id)"
|