@tracked_task
def fire_signal(signal, kwargs):
    for listener, l_signal in current_app.config['EVENT_LISTENERS']:
        if l_signal == signal:
            run_event_listener.delay(
                listener=listener,
                signal=signal,
                kwargs=kwargs,
            )
Tasks fire signals by spawning fire_signal tasks; they grab every
dataset/ETHPy150Open dropbox/changes/changes/jobs/signals.py/fire_signal