def __init__()

in src/pubsub/ipc_pubsub.py [0:0]

• 15 lines of code
• 1 McCabe index (conditional complexity)

    def __init__(self, message_callback, ipc_subscribe_topics, ipc_timeout=5):

        log.info('Initialising AWS Greengrass V2 IPC Topic PubSub Client')

        super().__init__()

        try:

            # PubSub timeout secs. 
            self.ipc_timeout = ipc_timeout
            
            # PubSub message callback.
            self.message_callback = message_callback

            # IPC Subscribe Topics
            self.ipc_subscribe_topics = ipc_subscribe_topics

            # Create the ipc_clients
            self.ipc_subscribe_client = awsiot.greengrasscoreipc.connect()
            self.ipc_publish_client = awsiot.greengrasscoreipc.connect()

            # Init IPC PubSub's
            self.init_topic_subscriber()
            self.init_topic_publisher()

        except InterruptedError as iErr: # pragma: no cover 
            log.error('INTERRUPTED_EXCEPTION: IPC Topic Publisher / Subscriber init was interrupted. ERROR MESSAGE: {}'.format(iErr))

        except Exception as err: # pragma: no cover 
            log.error('EXCEPTION: Exception occurred initialising AWS Greengrass IPC Topic PubSub. ERROR MESSAGE: {}'.format(err))