[
https://issues.apache.org/jira/browse/AIRFLOW-2356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553921#comment-16553921
]
Sergii Nechuiviter commented on AIRFLOW-2356:
---------------------------------------------
[~cpaulik] I am going to test such implementation in my work.
See draft atÂ
https://github.com/Sklavit/incubator-airflow/tree/v1-9-stable-dask-queue
> Support queues in dask using worker resources
> ---------------------------------------------
>
> Key: AIRFLOW-2356
> URL: https://issues.apache.org/jira/browse/AIRFLOW-2356
> Project: Apache Airflow
> Issue Type: Improvement
> Reporter: Christoph Paulik
> Priority: Minor
>
> Dask in Airflow does at the moment not support queues. I suggest to implement
> this by using [worker
> resources](https://distributed.readthedocs.io/en/latest/resources.html#example).
>
> A queue name would be a necessary worker resource that a dask worker must
> have to be able to compute a specific task.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
