manipatnam commented on issue #66335:
URL: https://github.com/apache/airflow/issues/66335#issuecomment-4384430727
@tirkarthi
```
Nested Loop Left Join (cost=1001.75..928157.61 rows=4169 width=4729)
(actual time=26086.261..35141.064 rows=756 loops=1)
Buffers: shared hit=158577 read=610220
I/O Timings: shared read=102185.075
-> Nested Loop Left Join (cost=1001.46..927219.79 rows=4169 width=3395)
(actual time=26086.226..35140.304 rows=756 loops=1)
Buffers: shared hit=158556 read=610220
I/O Timings: shared read=102185.075
-> Gather (cost=1001.17..924361.05 rows=4169 width=2803) (actual
time=26086.188..35139.498 rows=756 loops=1)
Workers Planned: 2
Workers Launched: 2
Buffers: shared hit=158535 read=610220
I/O Timings: shared read=102185.075
-> Nested Loop (cost=1.17..922944.15 rows=1737 width=2803)
(actual time=26083.792..35134.847 rows=252 loops=3)
Buffers: shared hit=158535 read=610220
I/O Timings: shared read=102185.075
-> Nested Loop (cost=0.61..915634.80 rows=1737
width=2070) (actual time=26083.768..35131.990 rows=252 loops=3)
Buffers: shared hit=154548 read=610220
I/O Timings: shared read=102185.075
-> Parallel Seq Scan on task_instance
(cost=0.06..905114.16 rows=1737 width=2007) (actual time=26083.697..35129.184
rows=252 loops=3)
Filter: ((COALESCE(end_date, now()) >=
'2026-05-05 19:49:33+00'::timestamp with time zone) AND (COALESCE(end_date,
now()) <= '2026-05-05 22:00:00+00'::timestamp with time zone) AND
((dag_id)::text = ANY
('{replication_catch_up_86400_seconds,ratings_fitch_mssql_download,bg_markit_bond_pricing_sftp_download,private_market_cash_transaction,pb_barclays_axe,airflow-create-conns-vars,bloomberg_portfolio_upload,sharepoint_legal_entity_sync,fund_admin_monthly_performance_mssql,populate_liquidity_dashboard,omegapoint_portfolio_upload,fund_admin_leveling_asc_elt,pb_baml_ingest,replication_sync_formpf_seconds,TPIL-website-data-email,bg_jpmchase_sftp_download,delticus_certificate_email_process,fund_admin_position_geneva_mtd_mssql,pb_alert_data_integrity,ce-ground-truth_snowflake_ingest,pb_morganstanley_ingest,primebroker_openpoint_priceserve_load,astro_db_cleanup,table_stale_checks,weekly_credit_card_tracker}'::text[])))
Rows Removed by Filter: 4729043
Buffers: shared hit=150587 read=610220
I/O Timings: shared read=102185.075
-> Index Only Scan using
dag_run_dag_id_run_id_key on dag_run (cost=0.55..6.06 rows=1 width=63) (actual
time=0.010..0.010 rows=1 loops=756)
Index Cond: ((dag_id =
(task_instance.dag_id)::text) AND (run_id = (task_instance.run_id)::text))
Heap Fetches: 932
Buffers: shared hit=3961
-> Index Scan using dag_run_dag_id_run_id_key on
dag_run dag_run_1 (cost=0.55..4.21 rows=1 width=796) (actual time=0.011..0.011
rows=1 loops=756)
Index Cond: (((dag_id)::text =
(dag_run.dag_id)::text) AND ((run_id)::text = (dag_run.run_id)::text))
Buffers: shared hit=3956
-> Memoize (cost=0.30..3.82 rows=1 width=592) (actual
time=0.000..0.000 rows=1 loops=756)
Cache Key: task_instance.dag_version_id
Cache Mode: logical
Hits: 749 Misses: 7 Evictions: 0 Overflows: 0 Memory
Usage: 2kB
Buffers: shared hit=21
-> Index Scan using dag_version_pkey on dag_version
dag_version_1 (cost=0.29..3.81 rows=1 width=592) (actual time=0.007..0.007
rows=1 loops=7)
Index Cond: (id = task_instance.dag_version_id)
Buffers: shared hit=21
-> Memoize (cost=0.28..3.58 rows=1 width=1334) (actual time=0.000..0.000
rows=1 loops=756)
Cache Key: dag_run_1.dag_id
Cache Mode: logical
Hits: 749 Misses: 7 Evictions: 0 Overflows: 0 Memory Usage: 4kB
Buffers: shared hit=21
-> Index Scan using dag_pkey on dag dag_1 (cost=0.27..3.57 rows=1
width=1334) (actual time=0.009..0.009 rows=1 loops=7)
Index Cond: ((dag_id)::text = (dag_run_1.dag_id)::text)
Buffers: shared hit=21
Planning:
Buffers: shared hit=370
Planning Time: 3.604 ms
Execution Time: 35141.278 ms
```
--
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]
