Basics
Guides
Resources
Commits
Use the LatestOnlyOperator.
LatestOnlyOperator
airflow/providers/standard/example_dags/example_latest_only.py[source]
latest_only = LatestOnlyOperator(task_id="latest_only")
Was this entry helpful?