@cronjobs.register
def enqueue_lag_monitor_task():
    measure_queue_lag.delay(datetime.now())
Fires a task that measures the queue lag.
dataset/ETHPy150Open mozilla/kitsune/kitsune/sumo/cron.py/enqueue_lag_monitor_task