def METHOD_NAME(fun):
    @wraps(fun)
    async def wrapped(request, *args, **kwargs):
        request['batch_telemetry'] = {'operation': fun.__name__}
        batch_id = request.match_info.get('batch_id')
        if batch_id is not None:
            request['batch_telemetry']['batch_id'] = batch_id
        job_id = request.match_info.get('job_id')
        if job_id is not None:
            request['batch_telemetry']['job_id'] = job_id
        return await fun(request, *args, **kwargs)
    return wrapped