| :py:mod:`airflow.executors.dask_executor` |
| ========================================= |
| |
| .. py:module:: airflow.executors.dask_executor |
| |
| .. autoapi-nested-parse:: |
| |
| DaskExecutor |
| |
| .. seealso:: |
| For more information on how the DaskExecutor works, take a look at the guide: |
| :ref:`executor:DaskExecutor` |
| |
| |
| |
| Module Contents |
| --------------- |
| |
| Classes |
| ~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.executors.dask_executor.DaskExecutor |
| |
| |
| |
| |
| .. py:class:: DaskExecutor(cluster_address=None) |
| |
| Bases: :py:obj:`airflow.executors.base_executor.BaseExecutor` |
| |
| DaskExecutor submits tasks to a Dask Distributed cluster. |
| |
| .. py:method:: start(self) -> None |
| |
| Executors may need to get things started. |
| |
| |
| .. py:method:: execute_async(self, key: airflow.models.taskinstance.TaskInstanceKey, command: airflow.executors.base_executor.CommandType, queue: Optional[str] = None, executor_config: Optional[Any] = None) -> None |
| |
| This method will execute the command asynchronously. |
| |
| :param key: Unique key for the task instance |
| :param command: Command to run |
| :param queue: name of the queue |
| :param executor_config: Configuration passed to the executor. |
| |
| |
| .. py:method:: sync(self) -> None |
| |
| Sync will get called periodically by the heartbeat method. |
| Executors should override this to perform gather statuses. |
| |
| |
| .. py:method:: end(self) -> None |
| |
| This method is called when the caller is done submitting job and |
| wants to wait synchronously for the job submitted previously to be |
| all done. |
| |
| |
| .. py:method:: terminate(self) |
| |
| This method is called when the daemon receives a SIGTERM |
| |
| |
| |
