code: def _create_session(self):
      # retry mechanism refers to
      # https://urllib3.readthedocs.io/en/latest/reference/urllib3.util.html#urllib3.util.Retry
      retry = Retry(
          total=MAX_RETRIES,
          redirect=MAX_REDIRECT,
          backoff_factor=BACKOFF_FACTOR,
      )
      s = requests.Session()
      # initialize headers
      s.headers.update({"Content-Type": "application/json"})
  
      http_adapter = HTTPAdapter(max_retries=retry)
      s.mount("http://", http_adapter)
      s.mount("https://", http_adapter)
      return s
  
imports: import json
  import logging
  import requests
  from requests.adapters import HTTPAdapter
  from urllib3.util.retry import Retry
label_desc: Use image node_id 2 for calling the PulsarManager obj's underlying member method code with example usage: obj._create_session() and returns: s