Why does individual run from UI only work with Celery/K8Executor? Why not DaskExecutor?

[lformant]

What precludes the DaskExecutor from being valid for run submission from the UI?

airflow/airflow/www/views.py

Line 1485 in c4d043d

flash("Only works with the Celery or Kubernetes executors, sorry", "error")

Thanks.

[ashb]

Likely nothing, this check likely predates the addition of the DaskExecutor and no one has gone to change it.

[lformant]

Cool, any chance DaskExecutor could be greenlit in the next version?

[potiuk]

You can make your PR to fix it @lformant . This has the highest chance of success if you lead it to completion. Airflow is a community-driven project so anyone can contribute.

[ghost]

Can confirm this works just fine by adding a section mimicking the Celery/KubernetesExecutor import try/excepts.

[lformant]

Great, @aa1371 since you have a working solution would you be willing to open the PR?

[ghost]

Sure I don't mind, but if you want to create the PR yourself go for it. The change is pretty straightforward. You can just copy the try/except from CeleryExecutor and change occurrences of celery -> dask