This is a dedicated watch page for a single video.
A company runs a daily ETL pipeline in Cloud Composer that loads data into BigQuery. They need to ensure that if the pipeline fails, they can easily reprocess just the failed tasks without duplicating successful work. Which Airflow feature should they implement?