src/sisy/consumers.py
def run_heartbeat(message):
    """Internal ``CLOCK_CHANNEL`` consumer to process task runs"""
    then = arrow.get(message['time'])
    now = arrow.get()

    if (now - then) > timezone.timedelta(seconds=(TICK_FREQ+1)):
        pass # discard old ticks
    else:
        Task.run_tasks()
def run_heartbeat(message):
    """Internal ``CLOCK_CHANNEL`` consumer to process task runs"""
    then = arrow.get(message['time'])
    now = arrow.get()

    if (now - then) > timezone.timedelta(seconds=(TICK_FREQ+1)):
        pass # discard old ticks
    else:
        Task.run_tasks()
Internal ``CLOCK_CHANNEL`` consumer to process task runs