def __on_assign()

in provider/consumer.py [0:0]

• 5 lines of code
• 3 McCabe index (conditional complexity)

    def __on_assign(self, consumer, partitions):
        logging.info('[{}] Completed partition assignment. Connected to broker(s)'.format(self.trigger))

        if self.currentState() == Consumer.State.Initializing and self.__shouldRun():
            logging.info('[{}] Setting consumer state to running.'.format(self.trigger))
            self.__recordState(Consumer.State.Running)