async def METHOD_NAME(task_run):
    future = PrefectFuture(
        key=str(task_run.id),
        name="foo",
        task_runner=None,
        _final_state=Completed(data="foo"),
    )
    future.task_run = task_run
    future._submitted.set()
    def gen_a():
        yield future
    def gen_b():
        yield range(2)
        yield gen_a()
        yield "b"
    assert await resolve_futures_to_data(gen_b()) == [range(2), ["foo"], "b"]