[PR] Simplify query for orphaned tasks [airflow]

2024-01-03 Thread via GitHub
dstandish opened a new pull request, #36566: URL: https://github.com/apache/airflow/pull/36566 Two changes here. First, previously we ended up with two joins to DagRun because the dag_run relationship attr is `lazy="joined"` and sqlalchemy was not using it. By setting to be lazy, we

Re: [PR] Simplify query for orphaned tasks [airflow]

2024-01-03 Thread via GitHub
uranusjr commented on code in PR #36566: URL: https://github.com/apache/airflow/pull/36566#discussion_r1441394346 ## airflow/jobs/scheduler_job_runner.py: ## @@ -1644,13 +1644,10 @@ def adopt_or_reset_orphaned_tasks(self, session: Session = NEW_SESSION) -> int:

Re: [PR] Simplify query for orphaned tasks [airflow]

2024-01-04 Thread via GitHub
dstandish commented on code in PR #36566: URL: https://github.com/apache/airflow/pull/36566#discussion_r1442045713 ## airflow/jobs/scheduler_job_runner.py: ## @@ -1644,13 +1644,10 @@ def adopt_or_reset_orphaned_tasks(self, session: Session = NEW_SESSION) -> int:

Re: [PR] Simplify query for orphaned tasks [airflow]

2024-01-19 Thread via GitHub
dstandish commented on PR #36566: URL: https://github.com/apache/airflow/pull/36566#issuecomment-1901209966 can i get an amen @jedcunningham @uranusjr @ephraimbuddy -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] Simplify query for orphaned tasks [airflow]

2024-01-22 Thread via GitHub
dstandish merged PR #36566: URL: https://github.com/apache/airflow/pull/36566 -- 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: commits-unsubscr...@airflo