sample_tick_scripts.tick

// alert if scheduler is down.
stream
    |from()
        .measurement('prefix_scheduler_heartbeat')
    |deadman(0.0, 5m)
        .id('AirflowSchedulerDown')
        .message('Airflow Scheduler is down')
        .log('/tmp/alert_logs.txt')
        .trigger_alert_method()

// alert if worker count does not match the required value
stream
    |from()
        .measurement('prefix_celery_workers')
    |window()
    	.period(5m)
    	.every(5m)
    |alert()
        .id('Celery Workers Count')
  	.crit(lambda: "value" <= 2)
	  .warn(lambda: "value" <= 3)
    .log('/tmp/alert_2.txt')
    .trigger_alert_method()

// reference: https://docs.influxdata.com/kapacitor/v1.5/tick/introduction/