parameters: (self, end_point: str)
docstring: Initialize the ModelServer by connecting to the ZMQ IPC endpoint
          :param end_point:  IPC endpoint
docstring_summary: Initialize the ModelServer by connecting to the ZMQ IPC endpoint
          :param end_point:  IPC endpoint
docstring_tokens: Initialize the ModelServer by connecting to the ZMQ IPC endpoint : param end_point : IPC endpoint
function: def __init__(self, end_point: str):
          """
          Initialize the ModelServer by connecting to the ZMQ IPC endpoint
          :param end_point:  IPC endpoint
          """
          # Establish ZMQ connection
          self.context = zmq.Context()
          self.socket = self.context.socket(zmq.DEALER)
          self.socket.set_string(zmq.IDENTITY, 'model')
          logging.debug(
              f"Python model trying to connect to manager at {end_point}")
          self.socket.connect(f"ipc://{end_point}")
          logging.info(f"Python model connected at {end_point}")
  
          # If the ModelServer is closing
          self._closing = False
  
          # Register the exit callback
          atexit.register(self.cleanup_zmq)
  
          # Global model map cache
          self.cache = dict()
  
          # Used to automatically resend messages until the messages are ack'd.
          self.next_msg_id = 0
          self.pending_msgs = {}
  
          # Notify the ModelServerManager that I am connected
          self._send_msg(self._next_msg_id(), 0, 0, ModelServer._make_response(
              Callback.CONNECTED, "", True, ""))
  
          # Model trainers/inferers
          self.model_managers = {ModelType.FORECAST: ForecastModel(),
                                 ModelType.OPERATING_UNIT: OUModel(),
                                 ModelType.INTERFERENCE: InterferenceModel()}
function_tokens: def __init__ ( self , end_point : str ) : # Establish ZMQ connection self . context = zmq . Context ( ) self . socket = self . context . socket ( zmq . DEALER ) self . socket . set_string ( zmq . IDENTITY , 'model' ) logging . debug ( f"Python model trying to connect to manager at {end_point}" ) self . socket . connect ( f"ipc://{end_point}" ) logging . info ( f"Python model connected at {end_point}" ) # If the ModelServer is closing self . _closing = False # Register the exit callback atexit . register ( self . cleanup_zmq ) # Global model map cache self . cache = dict ( ) # Used to automatically resend messages until the messages are ack'd. self . next_msg_id = 0 self . pending_msgs = { } # Notify the ModelServerManager that I am connected self . _send_msg ( self . _next_msg_id ( ) , 0 , 0 , ModelServer . _make_response ( Callback . CONNECTED , "" , True , "" ) ) # Model trainers/inferers self . model_managers = { ModelType . FORECAST : ForecastModel ( ) , ModelType . OPERATING_UNIT : OUModel ( ) , ModelType . INTERFERENCE : InterferenceModel ( ) }