Event loop is closed error

[anna_geller]

maybe this can help?

Best practices for using async in Prefect 2.0

When writing async flows/tasks, all the standard rules of async python apply. It’s a good practice to run any blocking code in a separate thread, e.g. running time.sleep in a separate worker thread here works well: from prefect.utilities.asyncutils import run_sync_in_worker_thread async def async_func(): if random.random() > 0.3: run_sync_in_worker_thread(time.sleep, 1) await asyncio.sleep(random.randint(1, 5)) return 1 But doing this instead: import asyncio import ran…