slee.py

import asyncio

from prefect import flow, task


@task
async def sleepy_task() -> None:
    await asyncio.sleep(15)


@flow(log_prints=True)
async def sleepy_flow() -> None:
    tasks = [sleepy_task.submit() for _ in range(100)]
    print("Waiting for all tasks to complete...")

    results = [t.result() for t in tasks]
    print(f"collected {len(results)} results")