# 使用 Dask 擴展
> 貢獻者：[@ImPerat0R\_](https://github.com/tssujt)、[@ThinkingChen](https://github.com/cdmikechen)
`DaskExecutor`允許您在 Dask 分布式集群中運行 Airflow 任務。
Dask 集群可以在單個機器上運行，也可以在遠程網絡上運行。有關完整詳細信息，請參閱[分布式文檔](https://distributed.readthedocs.io/) 。
要創建集群，首先啟動一個 Scheduler：
```py
# 一個本地集群的默認設置
DASK_HOST=127.0.0.1
DASK_PORT=8786
dask-scheduler --host $DASK_HOST --port $DASK_PORT
```
接下來，在任何可以連接到主機的計算機上啟動至少一個 Worker：
```py
dask-worker $DASK_HOST:$DASK_PORT
```
編輯`airflow.cfg`以將執行程序設置為`DaskExecutor`并在`[dask]`部分中提供 Dask Scheduler 地址。
請注意：
* 每個 Dask worker 必須能夠導入 Airflow 和您需要的任何依賴項。
* Dask 不支持隊列。如果使用隊列創建了 Airflow 任務，則會引發警告，但該任務會被提交給集群。
