seanmuth commented on PR #65602:
URL: https://github.com/apache/airflow/pull/65602#issuecomment-4289666051
## 0112 ti state updated_at:
Before:
```
=> EXPLAIN ANALYZE SELECT task_instance.id, task_instance.task_id,
task_instance.dag_id, task_instance.run_id, task_instance.map_index,
task_instance.state, task_instance.try_number, task_instance.updated_at,
dag_run_1.state AS state_1, dag_run_1.id AS id_1, dag_run_1.dag_id AS dag_id_1,
dag_run_1.queued_at, dag_run_1.logical_date, dag_run_1.start_date,
dag_run_1.end_date, dag_run_1.run_id AS run_id_1, dag_run_1.creating_job_id,
dag_run_1.run_type, dag_run_1.triggered_by, dag_run_1.triggering_user_name,
dag_run_1.conf, dag_run_1.data_interval_start, dag_run_1.data_interval_end,
dag_run_1.run_after, dag_run_1.last_scheduling_decision,
dag_run_1.log_template_id, dag_run_1.updated_at AS updated_at_1,
dag_run_1.clear_number, dag_run_1.backfill_id, dag_run_1.bundle_version,
dag_run_1.scheduled_by_job_id, dag_run_1.context_carrier,
dag_run_1.span_status, dag_run_1.created_dag_version_id
amorphous_intensity_2933_airflow-> FROM task_instance JOIN dag_run AS
dag_run_1 ON dag_run_1.dag_id = task_instance.dag_id AND dag_run_1.run_id =
task_instance.run_id
amorphous_intensity_2933_airflow-> WHERE task_instance.state IN ('success',
'failed') AND task_instance.updated_at >
'2026-04-21T15:01:46.266939+00:00'::timestamptz ORDER BY
task_instance.updated_at DESC;
QUERY PLAN
-------------------------------------------------------------------------------------------------------------------------------------------------------------------
Gather Merge (cost=2205049.03..2205315.52 rows=2284 width=497) (actual
time=17763.350..17763.503 rows=113 loops=1)
Workers Planned: 2
Workers Launched: 0
-> Sort (cost=2204049.01..2204051.86 rows=1142 width=497) (actual
time=17762.649..17762.666 rows=113 loops=1)
Sort Key: task_instance.updated_at DESC
Sort Method: quicksort Memory: 72kB
-> Nested Loop (cost=0.56..2203991.01 rows=1142 width=497)
(actual time=15626.348..17762.519 rows=113 loops=1)
-> Parallel Seq Scan on task_instance
(cost=0.00..2194356.62 rows=1142 width=165) (actual time=15626.305..17761.080
rows=113 loops=1)
Filter: (((state)::text = ANY
('{success,failed}'::text[])) AND (updated_at > '2026-04-21
15:01:46.266939+00'::timestamp with time zone))
Rows Removed by Filter: 27719173
-> Index Scan using dag_run_dag_id_run_id_key on dag_run
dag_run_1 (cost=0.56..8.44 rows=1 width=332) (actual time=0.012..0.012 rows=1
loops=113)
Index Cond: (((dag_id)::text =
(task_instance.dag_id)::text) AND ((run_id)::text =
(task_instance.run_id)::text))
Planning Time: 2.806 ms
Execution Time: 17763.586 ms
(14 rows)
```
After:
```
=> EXPLAIN ANALYZE SELECT task_instance.id, task_instance.task_id,
task_instance.dag_id, task_instance.run_id, task_instance.map_index,
task_instance.state, task_instance.try_number, task_instance.updated_at,
dag_run_1.state AS state_1, dag_run_1.id AS id_1, dag_run_1.dag_id AS dag_id_1,
dag_run_1.queued_at, dag_run_1.logical_date, dag_run_1.start_date,
dag_run_1.end_date, dag_run_1.run_id AS run_id_1, dag_run_1.creating_job_id,
dag_run_1.run_type, dag_run_1.triggered_by, dag_run_1.triggering_user_name,
dag_run_1.conf, dag_run_1.data_interval_start, dag_run_1.data_interval_end,
dag_run_1.run_after, dag_run_1.last_scheduling_decision,
dag_run_1.log_template_id, dag_run_1.updated_at AS updated_at_1,
dag_run_1.clear_number, dag_run_1.backfill_id, dag_run_1.bundle_version,
dag_run_1.scheduled_by_job_id, dag_run_1.context_carrier,
dag_run_1.span_status, dag_run_1.created_dag_version_id
FROM task_instance JOIN dag_run AS dag_run_1 ON dag_run_1.dag_id =
task_instance.dag_id AND dag_run_1.run_id = task_instance.run_id
WHERE task_instance.state IN ('success', 'failed') AND
task_instance.updated_at > '2026-04-21T15:01:46.266939+00:00'::timestamptz
ORDER BY task_instance.updated_at DESC;
QUERY PLAN
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Gather Merge (cost=647635.54..647820.92 rows=1612 width=497) (actual
time=547.047..554.723 rows=840 loops=1)
Workers Planned: 1
Workers Launched: 1
-> Sort (cost=646635.53..646639.56 rows=1612 width=497) (actual
time=543.573..543.611 rows=420 loops=2)
Sort Key: task_instance.updated_at DESC
Sort Method: quicksort Memory: 193kB
Worker 0: Sort Method: quicksort Memory: 236kB
-> Nested Loop (cost=1.12..646549.65 rows=1612 width=497) (actual
time=268.702..543.184 rows=420 loops=2)
-> Parallel Index Scan using idx_cre_ti_state_updated_at on
task_instance (cost=0.56..632950.23 rows=1612 width=165) (actual
time=268.654..538.282 rows=420 loops=2)
Index Cond: (updated_at > '2026-04-21
15:01:46.266939+00'::timestamp with time zone)
-> Index Scan using dag_run_dag_id_run_id_key on dag_run
dag_run_1 (cost=0.56..8.44 rows=1 width=332) (actual time=0.010..0.010 rows=1
loops=840)
Index Cond: (((dag_id)::text =
(task_instance.dag_id)::text) AND ((run_id)::text =
(task_instance.run_id)::text))
Planning Time: 1.918 ms
Execution Time: 554.807 ms
(14 rows)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
