dor-bernstein commented on issue #56219:
URL: https://github.com/apache/airflow/issues/56219#issuecomment-3350389611

   1. total dags - 571
   2. dag runs - 84,118
   3. dags passing the filter -32
   
   I see some queries which are slow and are in this shape:
   
   SELECT serialized_dag.data, serialized_dag.data_compressed, 
serialized_dag.id, serialized_dag.dag_id, serialized_dag.created_at, 
serialized_dag.last_updated, serialized_dag.dag_hash, 
serialized_dag.dag_version_id 
   FROM serialized_dag 
   WHERE serialized_dag.dag_version_id IN (SELECT task_instance.dag_version_id 
   FROM task_instance JOIN dag_run ON dag_run.dag_id = task_instance.dag_id AND 
dag_run.run_id = task_instance.run_id 
   WHERE dag_run.id IN (84225, 83924, 83642, 83081, 82660) AND 
serialized_dag.id != '01999979-0158-7c28-9714-c98c1b5891d1'::uuid)
   
   The fix for this query actually is just moving the last predicate outside of 
the brackets like this:
   SELECT serialized_dag.data, serialized_dag.data_compressed, 
serialized_dag.id, serialized_dag.dag_id, serialized_dag.created_at, 
serialized_dag.last_updated, serialized_dag.dag_hash, 
serialized_dag.dag_version_id 
   FROM serialized_dag 
   WHERE serialized_dag.dag_version_id IN (SELECT task_instance.dag_version_id 
   FROM task_instance JOIN dag_run ON dag_run.dag_id = task_instance.dag_id AND 
dag_run.run_id = task_instance.run_id 
   WHERE dag_run.id IN (84225, 83924, 83642, 83081, 82660))
   AND serialized_dag.id != '01999979-0158-7c28-9714-c98c1b5891d1'::uuid
   
   


-- 
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]

Reply via email to