@cached_property
    def on_finish(self):
        return blinker.Signal(doc='Emitted after the a message is finished.')
Test that scheduling flows works.
dataset/ETHPy150Open wtolson/gnsq/gnsq/nsqd.py/Nsqd.on_finish--crossover with--dataset/ETHPy150Open google/grr/grr/gui/plugins/flow_management_test.py/TestFlowManagement.testFlowManagement