prefect_async_example.py

# This is Prefect 2.0b9

import asyncio

from prefect import flow, task


@task
async def shout(number):
    asyncio.sleep(1)
    print(f"#{number}")


@flow()
async def count_to(highest_number):
    for number in range(highest_number):
        await shout(number)


asyncio.run(count_to(3))