airflow.providers.edge3.cli.dataclasses¶

类¶

`MaintenanceMarker`	维护模式状态。
`WorkerStatus`	工作节点的状态。
`Job`	包含作为捆绑包执行任务/作业所需的所有信息。

模块内容¶

class airflow.providers.edge3.cli.dataclasses.MaintenanceMarker[source]¶

维护模式状态。

maintenance: str[source]¶

comments: str | None[source]¶

property json: str[source]¶

获取 JSON 格式的维护状态。

static from_json(json_str)[source]¶

从 JSON 创建一个 Maintenance 对象。

class airflow.providers.edge3.cli.dataclasses.WorkerStatus[source]¶

工作节点的状态。

job_count: int[source]¶

jobs: list[source]¶

state: airflow.providers.edge3.models.edge_worker.EdgeWorkerState[source]¶

maintenance: bool[source]¶

maintenance_comments: str | None[source]¶

drain: bool[source]¶

property json: str[source]¶

获取 JSON 格式的状态。

static from_json(json_str)[source]¶

从 JSON 创建一个 WorkerStatus 对象。

class airflow.providers.edge3.cli.dataclasses.Job[source]¶

包含作为捆绑包执行任务/作业所需的所有信息。

edge_job: airflow.providers.edge3.worker_api.datamodels.EdgeJobFetched[source]¶

process: psutil.Popen | multiprocessing.Process[source]¶

logfile: pathlib.Path[source]¶

logsize: int[source]¶: 日志文件的最后大小，上次推送日志块时的位置。

property is_running: bool[source]¶

检查作业是否仍在运行。

property is_success: bool[source]¶

检查作业是否成功。

此条目有帮助吗？