From b7eccd352a4f703c15902fd953882953592e9e0f Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Mon, 16 Mar 2026 15:58:35 +0800
Subject: [PATCH] bugfix

---
 dagflow/dagflow.py | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index e1a8b92..525396a 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -558,12 +558,10 @@ async def get_exists_workflows(request):
 async def new_instance(request, flow_def_id, params_kw):
 	env = request._run_ns
 	orgid = await env.get_userorgid()
-	async with get_sor_context(env, 'dagflow') as sor:
-		engine = get_engine()
-		fiid = await engine.create_instance(sor, orgid, 
-					flow_def_id, ctx=params_kw)
-		return fiid
-	return None
+	engine = get_engine()
+	fiid = await engine.create_instance(orgid, 
+				flow_def_id, ctx=params_kw)
+	return fiid
 
 async def add_new_workflow(request, params_kw={}):
 	name = params_kw.name