async def METHOD_NAME(dataflow):
    async for ctx, results in run(
        dataflow,
        [
            Input(
                value=[fail_and_retry.op.outputs["result"].name],
                definition=GetSingle.op.inputs["spec"],
            ),
        ],
    ):
        yield results