Jonathan Aschan
09/20/2023, 12:38 PMimport asyncio
from typing import Any
from prefect import flow
@flow
async def subflow(should_fail: bool = False):
if should_fail:
raise ValueError("I failed!")
return 42
@flow
async def create_sub_flows():
parallel_subflows: list[Any] = []
for i in range(10):
parallel_subflows.append(subflow(i % 2 == 0))
await asyncio.gather(*parallel_subflows)
if __name__ == '__main__':
asyncio.run(create_sub_flows())