Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Max active tasks to be evaluated per dag run #42953

Merged

Conversation

dstandish
Copy link
Contributor

@dstandish dstandish commented Oct 11, 2024

Pursuant to mailing list vote, this PR changes meaning of DAG.max_active_tasks from "per dag" to "per dag run"

Vote thread: https://lists.apache.org/thread/9o84d3yn934m32gtlpokpwtbbmtxj47l

@boring-cyborg boring-cyborg bot added the area:Scheduler including HA (high availability) scheduler label Oct 11, 2024
@dstandish dstandish force-pushed the max-active-tasks-evaluated-per-dag-run branch from db653aa to 8986cb1 Compare October 15, 2024 17:37
@dstandish dstandish marked this pull request as ready for review October 15, 2024 21:09
airflow/jobs/scheduler_job_runner.py Outdated Show resolved Hide resolved
airflow/jobs/scheduler_job_runner.py Outdated Show resolved Hide resolved
newsfragments/42953.significant Outdated Show resolved Hide resolved
@dstandish dstandish force-pushed the max-active-tasks-evaluated-per-dag-run branch from f83bdc9 to dd8cdbc Compare October 17, 2024 18:44
@ephraimbuddy
Copy link
Contributor

Should the config change to max_active_tasks_per_dagrun?

@dstandish
Copy link
Contributor Author

dstandish commented Oct 17, 2024

Should the config change to max_active_tasks_per_dagrun?

You know it was unspecified before, and remains unspecified now. Personally, I like the brevity of it how it is. I feel when the params are super long it's harder to understand and worse user experience.

Of course the question of naming can be revisited between now and 3.0

@dstandish dstandish merged commit ae96933 into apache:main Oct 17, 2024
51 checks passed
@dstandish dstandish deleted the max-active-tasks-evaluated-per-dag-run branch October 17, 2024 21:07
harjeevanmaan pushed a commit to harjeevanmaan/airflow that referenced this pull request Oct 23, 2024
This behavior change was accepted by lazy consensus here: https://lists.apache.org/thread/9o84d3yn934m32gtlpokpwtbbmtxj47l.

Previously max_active_tasks was evaluated across all runs of a dag.

Co-authored-by: Wei Lee <[email protected]>
PaulKobow7536 pushed a commit to PaulKobow7536/airflow that referenced this pull request Oct 24, 2024
This behavior change was accepted by lazy consensus here: https://lists.apache.org/thread/9o84d3yn934m32gtlpokpwtbbmtxj47l.

Previously max_active_tasks was evaluated across all runs of a dag.

Co-authored-by: Wei Lee <[email protected]>
ellisms pushed a commit to ellisms/airflow that referenced this pull request Nov 13, 2024
This behavior change was accepted by lazy consensus here: https://lists.apache.org/thread/9o84d3yn934m32gtlpokpwtbbmtxj47l.

Previously max_active_tasks was evaluated across all runs of a dag.

Co-authored-by: Wei Lee <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
area:Scheduler including HA (high availability) scheduler
Projects
Development

Successfully merging this pull request may close these issues.

4 participants