Method create_session

dwave/cloud/client/base.py:589–627

Create a new requests session based on client's (self) params. Note: since `requests.Session` is NOT thread-safe, every thread should create and use an isolated session.

(self)

        pass

    def create_session(self):
        """Create a new requests session based on client's (self) params.

        Note: since `requests.Session` is NOT thread-safe, every thread should
        create and use an isolated session.
        """

        # allow endpoint path to not end with /
        endpoint = self.config.endpoint
        if not endpoint.endswith('/'):
            endpoint += '/'

        session = self._Session(base_url=endpoint, strict_mode=True,
                                on_deprecation=self._DEFAULT_ON_DEPRECATION_CONFIG)
        session.mount('http://', PretimedHTTPAdapter(
            timeout=self.config.request_timeout,
            max_retries=self.config.request_retry.to_urllib3_retry()))
        session.mount('https://', PretimedHTTPAdapter(
            timeout=self.config.request_timeout,
            max_retries=self.config.request_retry.to_urllib3_retry()))

        session.headers.update({'User-Agent': default_user_agent()})
        if self.config.headers:
            session.headers.update(self.config.headers)
        if self.config.token:
            session.headers.update({'X-Auth-Token': self.config.token})
        if self.config.cert:
            session.cert = self.config.cert

        session.proxies = {'http': self.config.proxy, 'https': self.config.proxy}
        if self.config.permissive_ssl:
            session.verify = False
        if self.config.connection_close:
            session.headers.update({'Connection': 'close'})

        # Debug-log headers
        logger.trace("create_session(session.headers=%r)", session.headers)

        return session

    def _shutdown_threads(self, wait: bool = True):
        # Finish all the work that requires the connection