Raimundo Pereira De Souza Neto
03/29/2022, 5:35 PMprefect = "2.0a13"
, I did read this link, but I'm using async flows.
More infos in the thread.Raimundo Pereira De Souza Neto
03/29/2022, 5:36 PM@flow(name="AutomaticLostFlow")
async def automatic_lost_flow() -> None:
await automatic_lost_task()
My async task:
@task(name="AutomaticLostTask")
async def automatic_lost_task():
logger = get_run_logger()
r = await lost.automatic_lost()
<http://logger.info|logger.info>(f"{r} onboardings gone to lost stage")
lost.automatic_lost()
is an async query in the databaseRaimundo Pereira De Souza Neto
03/29/2022, 5:38 PMautomatic_lost_flow()
)Anna Geller
Anna Geller
Raimundo Pereira De Souza Neto
03/29/2022, 5:42 PM