def run_heartbeat(message):
then = arrow.get(message['<STR_LIT:time>'])<EOL>now = arrow.get()<EOL>if (now - then) > timezone.timedelta(seconds=(TICK_FREQ+<NUM_LIT:1>)):<EOL><INDENT>pass <EOL><DEDENT>else:<EOL><INDENT>Task.run_tasks()<EOL><DEDENT>
Internal ``CLOCK_CHANNEL`` consumer to process task runs