Function dummy_async_inner

verl/verl/utils/transferqueue_utils.py:318–320

(*args, **kwargs)

        @wraps(func)
        async def dummy_async_inner(*args, **kwargs):
            output = await func(*args, **kwargs)
            return output

        wrapper_inner = inner if is_transferqueue_enabled else dummy_inner
        wrapper_async_inner = async_inner if is_transferqueue_enabled else dummy_async_inner