LatestOnlyOperator

Use the LatestOnlyOperator.

airflow/example_dags/example_latest_only.py

latest_only = LatestOnlyOperator(task_id="latest_only")

Was this entry helpful?