def __init__()

in src/influxDBTokenStreamHandler.py [0:0]

• 6 lines of code
• 2 McCabe index (conditional complexity)

    def __init__(self, influxDB_json, publish_topic):
        super().__init__()
        # We need a separate IPC client for publishing
        self.influxDB_json = influxDB_json
        self.publish_topic = publish_topic
        self.publish_client = awsiot.greengrasscoreipc.connect()
        logging.info("Initialized InfluxDBTokenStreamHandler")