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

Support DaskExecutor #614

Open
3 of 4 tasks
torse opened this issue Jun 21, 2022 · 0 comments
Open
3 of 4 tasks

Support DaskExecutor #614

torse opened this issue Jun 21, 2022 · 0 comments
Labels
kind/enhancement kind - new features or changes

Comments

@torse
Copy link

torse commented Jun 21, 2022

Checks

Motivation

I would like to use the DaskExecutor to offload task execution to our Dask cluster as documented here: https://airflow.apache.org/docs/apache-airflow/stable/executor/dask.html. Therefore I've updated my values.yaml like this:

airflow:
  executor: DaskExecutor
  config:
    AIRFLOW__DASK__CLUSTER_ADDRESS: "dask-scheduler:8786"

However, the DaskExecutor seems to be unsupported by the chart as the following error is thrown when upgrading:

helm upgrade --install --cleanup-on-fail airflow airflow-stable/airflow -f /local/.../values-airflow.yml
Error: UPGRADE FAILED: execution error at (airflow/templates/_helpers/validate-values.tpl:29:5): The `airflow.executor` must be one of: [CeleryExecutor, CeleryKubernetesExecutor, KubernetesExecutor]!

Implementation

No response

Are you willing & able to help?

  • I am able to submit a PR!
  • I can help test the feature!
@torse torse added the kind/enhancement kind - new features or changes label Jun 21, 2022
@torse torse changed the title Supportz DaskExecutor Support DaskExecutor Jun 21, 2022
@thesuperzapper thesuperzapper added this to Triage | Needs PR in Issue Triage and PR Tracking Jun 22, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
kind/enhancement kind - new features or changes
Projects
Development

No branches or pull requests

1 participant