bugfix

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