Function async_child_flow

integration-tests/test_nested_cancellation.py:52–55

(marker_dir: str)

@flow(on_cancellation=[child_cancel_hook], log_prints=True)
async def async_child_flow(marker_dir: str):
    Path(marker_dir, CHILD_STARTED_MARKER).write_text("started")
    while True:
        await asyncio.sleep(0.2)


@flow(on_cancellation=[parent_cancel_hook], log_prints=True)