What is the best approach to calling an async function within a Prefect task? I have to call the Azure Eventhub client which is async all the way down, from my straight synchronous Prefect task. I've tried calling the async functions like so;

asyncio.run(client.send_batch(event_data_batch))

but I get errors like

RuntimeError: Event loop is closed

Any advice?

This is similar to what I’ve done. I’ve created

async def foo

functions without task decorators and then inside a task I’ve done

asyncio.run(foo)

and it’s worked well.

Hmm, there's more than one async call in my task, so maybe I should spin it out and then only have one async call in my task...

Yeah that sounds like an idea

@Marvin archive “Using async functions in Prefect tasks”