diff --git a/wwwroot/manual_step.dspy b/wwwroot/manual_step.dspy
index 87816f5..6508e69 100644
--- a/wwwroot/manual_step.dspy
+++ b/wwwroot/manual_step.dspy
@@ -1,2 +1,8 @@
-await flow_engines[0].bgtask()
-return 'OK'
+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)"