https://prefect.io logo
e

Esdras Lopes Nani

09/29/2022, 5:43 PM
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
👍 1
5 Views