Skip to content

Instantly share code, notes, and snippets.

@nickefy
nickefy / airflow sensors.py
Last active May 17, 2022 15:35
example dag for sensors
from airflow.exceptions import AirflowException
from airflow import models
from airflow import DAG
from datetime import datetime, timedelta
from airflow.utils.email import send_email
from dateutil.relativedelta import relativedelta
import os
schedule_interval_dag = timedelta(days=1)