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

Add CeleryKubernetesExecutor #10901

Merged
merged 1 commit into from
Sep 15, 2020
Merged

Add CeleryKubernetesExecutor #10901

merged 1 commit into from
Sep 15, 2020

Conversation

pingzh
Copy link
Contributor

@pingzh pingzh commented Sep 12, 2020

it consists of CeleryExecutor and KubernetesExecutor, which allows users
to route their tasks to either Kubernetes or Celery based on the queue
defined on a task

(I re-forked the apache/airflow repo, mine was the incubator-airflow)

Orignal PR is: #10654


^ 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:docs area:Scheduler including HA (high availability) scheduler labels Sep 12, 2020
Copy link
Member

@turbaszek turbaszek left a comment

Choose a reason for hiding this comment

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

I'm ok with merging the current scope of this PR. The ideas from #10654 (comment) can be implemented in follow up PR. @dimberman what do you think?

airflow/config_templates/config.yml Outdated Show resolved Hide resolved
airflow/executors/celery_kubernetes_executor.py Outdated Show resolved Hide resolved
Copy link
Member

@potiuk potiuk left a comment

Choose a reason for hiding this comment

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

Nice. Few nits about the docs where I agree with @turbaszek's proposals

it consists of CeleryExecutor and KubernetesExecutor, which allows users
to route their tasks to either Kubernetes or Celery based on the queue
defined on a task
@pingzh
Copy link
Contributor Author

pingzh commented Sep 15, 2020

thanks @turbaszek and @potiuk for the suggestions and making the docs better.

@turbaszek turbaszek merged commit 9616518 into apache:master Sep 15, 2020
@pingzh pingzh deleted the ping.zhang-job-dispatcher branch September 15, 2020 16:25
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
None yet
Development

Successfully merging this pull request may close these issues.

3 participants