async def METHOD_NAME(self, function, *args, **kwargs):
    # type: (ArqRedis, str, *Any, **Any) -> Optional[Job]
    hub = Hub.current
    if hub.get_integration(ArqIntegration) is None:
        return await old_enqueue_job(self, function, *args, **kwargs)
    with hub.start_span(op=OP.QUEUE_SUBMIT_ARQ, description=function):
        return await old_enqueue_job(self, function, *args, **kwargs)