airflow.providers.edge3.executors.edge_executor

属性

TaskTuple

PARALLELISM

类

EdgeExecutor

EdgeExecutor 的实现，通过 HTTP 将工作分发给 Edge Worker。

模块内容

airflow.providers.edge3.executors.edge_executor.TaskTuple[source]
airflow.providers.edge3.executors.edge_executor.PARALLELISM: int[source]
class airflow.providers.edge3.executors.edge_executor.EdgeExecutor(parallelism=PARALLELISM)[source]

基类： airflow.executors.base_executor.BaseExecutor

EdgeExecutor 的实现，通过 HTTP 将工作分发给 Edge Worker。

last_reported_state: dict[airflow.models.taskinstancekey.TaskInstanceKey, airflow.models.taskinstance.TaskInstanceState][source]
start(session=NEW_SESSION)[source]

如果 EdgeExecutor provider 首次加载，确保表存在。

execute_async(key, command, queue=None, executor_config=None, session=NEW_SESSION)[source]

异步执行。Airflow 2.10 执行任务的入口点。

queue_workload(workload, session=NEW_SESSION)[source]

将新工作负载放入队列。Airflow 3 执行任务的入口点。

sync(session=NEW_SESSION)[source]

Sync 方法将由心跳方法定期调用。

end()[source]

结束执行器。

terminate()[source]

终止执行器不执行任何操作。

try_adopt_task_instances(tis)[source]

尝试接管因 SchedulerJob 终止而被抛弃的正在运行的任务实例。

任何未被接管的任务实例将被调度器清理（然后变得符合重新调度的条件）

返回：

任何未能被接管的任务实例

返回类型：

collections.abc.Sequence[airflow.models.taskinstance.TaskInstance]

static get_cli_commands()[source]

提供包含在 Airflow CLI 中的 CLI 命令。

覆盖此方法以通过 Airflow CLI 公开管理此执行器的命令。这可以是设置/拆卸执行器、检查状态等的命令。请确保为这些命令选择唯一的名称，以避免冲突。

此条目有帮助吗？