@cronjobs.register
def enqueue_lag_monitor_task():
 measure_queue_lag.delay(datetime.now())

@ cronjobs . register def enqueue_lag_monitor_task ( ) : measure_queue_lag . delay ( datetime . now ( ) )
fires a task that measures the queue lag .