Skip to content

Instantly share code, notes, and snippets.

from datetime import datetime
from airflow.models import DAG
from airflow.operators.dummy_operator import DummyOperator
from airflow.operators.latest_only_operator import LatestOnlyOperator
dag = DAG(dag_id='airflow_719', start_date=datetime(2017, 4, 1), schedule_interval='@hourly', catchup=True)
latest_only = LatestOnlyOperator(
task_id='latest_only',

Keybase proof

I hereby claim:

  • I am dhuang on github.
  • I am dhuang (https://keybase.io/dhuang) on keybase.
  • I have a public key whose fingerprint is 7E33 BC2A 1402 08D9 ADE2 07BD A74F 8501 82B1 EF8D

To claim this, I am signing this object: