diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index ef51024..e8fd8e3 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -185,7 +185,7 @@ where backid=${backid}$ 'status': 'running', 'ctx': json.dumps(ctx or {}), 'created_at': timestampstr() - }) + } await sor.C('flow_instance', ns.copy()) await self.create_start_node_execution(sor, ns) return iid