def run(self):

        raise NotImplementedError("Subclasses of Node should implement the run() method")
Loop over incoming messages from the queue in a blocking fashion. Set `polling` for the check interval in seconds.
dataset/ETHPy150Open Stiivi/brewery/brewery/nodes/base.py/Node.run--crossover with--dataset/ETHPy150Open harelba/tail2kafka/kafka/consumer.py/Consumer.loop