yumoqing/dagflow
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2026-03-16 16:32:33 +08:00
parent 1730e233df
commit bb0a1d89e4
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dagflow/dagflow.py
View File

@ -14,7 +14,7 @@ Features:
import asyncio import asyncio
import yaml import yaml
from random import randint from random import randint
from appPublic.log import debug from appPublic.log import debug, exception, error, info
from appPublic.timeUtils import timestampstr from appPublic.timeUtils import timestampstr
from sqlor.dbpools import get_sor_context from sqlor.dbpools import get_sor_context
@ -153,8 +153,9 @@ where backid=${backid}$
aio = await sor.sqlExe(sql,{ aio = await sor.sqlExe(sql,{
'backid': self.backid 'backid': self.backid
}) })
debug(f'aio={aio}')
for r in aio: for r in aio:
await elf.step(r) await self.step(r)
await asyncio.sleep(1) await asyncio.sleep(1)
async def create_definition(self, org_id, name, description, version, dsl_text, ctxfields): async def create_definition(self, org_id, name, description, version, dsl_text, ctxfields):