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

Rename task_concurrency to max_active_tis_per_dag #17708

Merged
merged 1 commit into from
Aug 19, 2021

Conversation

kaxil
Copy link
Member

@kaxil kaxil commented Aug 19, 2021

Follow-up of #16267

Renames task_concurrency to max_active_tis_per_dag

Some of Airflow's concurrency settings have been a source of confusion for a lot of users (including me), for example:

This PR is an attempt to make the settings easier to understand

ToDo:

  • Add note in UPDATING.md

^ Add meaningful description above

Read the Pull Request Guidelines for more information.
In case of fundamental code change, Airflow Improvement Proposal (AIP) is needed.
In case of a new dependency, check compliance with the ASF 3rd Party License Policy.
In case of backwards incompatible changes please leave a note in UPDATING.md.

@boring-cyborg boring-cyborg bot added area:Scheduler including HA (high availability) scheduler area:serialization kind:documentation labels Aug 19, 2021
@kaxil kaxil added this to the Airflow 2.2 milestone Aug 19, 2021
@kaxil kaxil force-pushed the task-concurrency-rename branch from adb98e2 to ce5f881 Compare August 19, 2021 01:27
@@ -887,6 +887,7 @@ def test_no_new_fields_added_to_base_operator(self):
'executor_config': {},
'inlets': [],
'label': '10',
'max_active_tis_per_dag': None,
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

What's the purpose of this test BTW? We had another PR About it and I was not sure why we have the list here.

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This list just makes sure that if new fields are added to the base operator we add it here, in case it needs any special treatment for DAG Serialization (helpful if they are dicts and lists)

@github-actions github-actions bot added the full tests needed We need to run full set of tests for this PR to merge label Aug 19, 2021
@github-actions
Copy link

The PR most likely needs to run full matrix of tests because it modifies parts of the core of Airflow. However, committers might decide to merge it quickly and take the risk. If they don't merge it quickly - please rebase it to the latest main at your convenience, or amend the last commit of the PR, and push it with --force-with-lease.

@kaxil kaxil force-pushed the task-concurrency-rename branch from ce5f881 to 4f1d55c Compare August 19, 2021 13:04
@kaxil kaxil marked this pull request as ready for review August 19, 2021 14:56
@kaxil kaxil requested a review from XD-DENG as a code owner August 19, 2021 14:56
Follow-up of apache#16267

Renames `task_concurrency` to `max_active_tis_per_dag`

Some of Airflow's concurrency settings have been a source of confusion for a lot of users (including me), for example:

https://stackoverflow.com/questions/56370720/how-to-control-the-parallelism-or-concurrency-of-an-airflow-installation
https://stackoverflow.com/questions/38200666/airflow-parallelism
This PR is an attempt to make the settings easier to understand
@kaxil kaxil force-pushed the task-concurrency-rename branch from 4f1d55c to 5176677 Compare August 19, 2021 15:04
@kaxil kaxil merged commit 35a6c30 into apache:main Aug 19, 2021
@kaxil kaxil deleted the task-concurrency-rename branch August 19, 2021 15:05
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 area:serialization full tests needed We need to run full set of tests for this PR to merge kind:documentation
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants