potiuk commented on pull request #14792: URL: https://github.com/apache/airflow/pull/14792#issuecomment-799816772
Also the number of queries seems to be affected by the changes but there is likely something else that affects it 'slighty` https://github.com/apache/airflow/runs/2116031674?check_suite_focus=true#step:6:10600: We got 196 queries here instead of 196 and it is puzzling why: ``` E AssertionError: The expected number of db queries is 195. The current number is 196. E E Recorded query locations: E test_scheduler_job.py:test_execute_queries_count_with_harvested_dags>scheduler_job.py:_run_scheduler_loop>scheduler_job.py:adopt_or_reset_orphaned_tasks:1839: 1 E test_scheduler_job.py:test_execute_queries_count_with_harvested_dags>scheduler_job.py:_run_scheduler_loop>scheduler_job.py:adopt_or_reset_orphaned_tasks:1867: 1 E scheduler_job.py:_run_scheduler_loop>scheduler_job.py:adopt_or_reset_orphaned_tasks>taskinstance.py:__repr__:899: 100 E test_scheduler_job.py:test_execute_queries_count_with_harvested_dags>scheduler_job.py:_run_scheduler_loop>scheduler_job.py:adopt_or_reset_orphaned_tasks:1893: 1 E scheduler_job.py:_do_scheduling>retries.py:wrapped_function>scheduler_job.py:_create_dagruns_for_dags:1573: 1 E retries.py:wrapped_function>scheduler_job.py:_create_dagruns_for_dags>scheduler_job.py:_create_dag_runs:1592: 1 E dagbag.py:get_dag>dagbag.py:_add_dag_from_db>serialized_dag.py:get:229: 11 E scheduler_job.py:_create_dagruns_for_dags>scheduler_job.py:_create_dag_runs>dag.py:create_dagrun:1781: 10 E dag.py:create_dagrun>dagrun.py:verify_integrity>dagrun.py:get_task_instances:329: 10 E scheduler_job.py:_create_dag_runs>dag.py:create_dagrun>dagrun.py:verify_integrity:674: 10 E scheduler_job.py:_create_dagruns_for_dags>scheduler_job.py:_create_dag_runs>scheduler_job.py:_update_dag_next_dagruns:1646: 1 E scheduler_job.py:_do_scheduling>retries.py:wrapped_function>scheduler_job.py:_create_dagruns_for_dags:1576: 1 E test_scheduler_job.py:test_execute_queries_count_with_harvested_dags>scheduler_job.py:_run_scheduler_loop>scheduler_job.py:_do_scheduling:1514: 1 E scheduler_job.py:_schedule_dag_run>scheduler_job.py:_verify_integrity_if_dag_changed>serialized_dag.py:get_latest_version_hash:285: 10 E dagrun.py:update_state>dagrun.py:task_instance_scheduling_decisions>dagrun.py:get_task_instances:329: 10 E scheduler_job.py:_do_scheduling>scheduler_job.py:_schedule_dag_run>dagrun.py:update_state:480: 10 E scheduler_job.py:_do_scheduling>scheduler_job.py:_schedule_dag_run>dagrun.py:schedule_tis:767: 10 E test_scheduler_job.py:test_execute_queries_count_with_harvested_dags>scheduler_job.py:_run_scheduler_loop>scheduler_job.py:_do_scheduling:1530: 1 E scheduler_job.py:_critical_section_execute_task_instances>scheduler_job.py:_executable_task_instances_to_queued>pool.py:slots_stats:107: 1 E scheduler_job.py:_critical_section_execute_task_instances>scheduler_job.py:_executable_task_instances_to_queued>pool.py:slots_stats:114: 1 E scheduler_job.py:_do_scheduling>scheduler_job.py:_critical_section_execute_task_instances>scheduler_job.py:_executable_task_instances_to_queued:934: 1 E scheduler_job.py:_critical_section_execute_task_instances>scheduler_job.py:_executable_task_instances_to_queued><string>:<lambda>:1: 1 E scheduler_job.py:_critical_section_execute_task_instances>scheduler_job.py:_executable_task_instances_to_queued>scheduler_job.py:__get_concurrency_maps:879: 1 E scheduler_job.py:_do_scheduling>scheduler_job.py:_critical_section_execute_task_instances>scheduler_job.py:_executable_task_instances_to_queued:1075: 1 ``` ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
