def on_request(self, request: PipelineRequest[HTTPRequestType]) -> None:
        """Updates with the given request id before sending the request to the next policy.

        :param request: The PipelineRequest object
        :type request: ~azure.core.pipeline.PipelineRequest
        """
        request_id = unset = object()
        if "request_id" in request.context.options:
            request_id = request.context.options.pop("request_id")
            if request_id is None:
                return
        elif self._request_id is None:
            return
        elif self._request_id is not _Unset:
            if self._request_id_header_name in request.http_request.headers:
                return
            request_id = self._request_id
        elif self._auto_request_id:
            if self._request_id_header_name in request.http_request.headers:
                return
            request_id = str(uuid.uuid1())
        if request_id is not unset:
            header = {self._request_id_header_name: cast(str, request_id)}
            request.http_request.headers.update(header)
Updates with the given request id before sending the request to the next policy.

        :param request: The PipelineRequest object
        :type request: ~azure.core.pipeline.PipelineRequest
        
Solutions/CyberArkAudit/Data Connectors/.python_packages/lib/site-packages/azure/core/pipeline/policies/_universal.py