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):
    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 ) : 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
Internal CLOCK_CHANNEL consumer to process task runs