functional async flow within a async function -> RuntimeError: cannot reuse already awaited coroutine

[amoallim15]

Description

Running the example below throws this error. Please advise.

File "/Users/*****/Library/Application Support/hatch/env/virtual/agent/D2qYGUjn/agent/lib/python3.12/site-packages/prefect/utilities/asyncutils.py", line 231, in coroutine_wrapper
    return await task
           ^^^^^^^^^^
RuntimeError: cannot reuse already awaited coroutine

Example Code

import asyncio
from controlflow import flow


@flow
async def main_flow():
    return await cf.run_async(
        "Say hello.",
        result_type=str,
    )

async def runner():
    result = await main_flow()

asyncio.run(runner())

Version Information

controlflow version = 0.8.2

Additional Context

No response

[jlowin]

I apologize for missing this somehow -- fix PR'd and will go out shortly.