Hi all!
I'm currently developing a flow with async and sync tasks. Tasks A and B run successfully but the execution freezes and I even can't see the log for task c, the last log is
Task run 'b' - Completed()
. If I force task c to be async runs without a problem. Is that a current bug? Using Prefect 2.3.1
Copy code
@task
async def a():
# do async
@task
async def b():
# do async
@task
def c():
# do sync
@flow
async def main():
a = await a()
b = await b(wait_for=[a])
c = c(wait_for=[b])
asyncio.run(main())
Thanks!
✅ 1
s
Serina
09/29/2022, 6:36 PM
Hey @Esdras Lopes Nani! Thank you for providing a reproducible example. I believe that this item is on the roadmap 🙂 Please see this already existing issue as I believe it describes what you may be experiencing:
https://github.com/PrefectHQ/prefect/issues/6318
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.