@cached_property
    def on_message(self):
        return blinker.Signal(doc='Emitted when a message frame is received.')
Returns the outputs of the Tasks returned by :py:meth:`requires`
dataset/ETHPy150Open wtolson/gnsq/gnsq/nsqd.py/Nsqd.on_message--crossover with--dataset/ETHPy150Open spotify/luigi/luigi/task.py/Task.input