airflow.providers.edge3.models.edge_job¶

类¶

EdgeJobModel

在 Edge Worker 上排队、等待或运行的作业。

模块内容¶

类 airflow.providers.edge3.models.edge_job.EdgeJobModel(dag_id, task_id, run_id, map_index, try_number, state, queue, concurrency_slots, command, queued_dttm=None, edge_worker=None, last_update=None)[来源]¶

基类: airflow.models.base.Base, airflow.utils.log.logging_mixin.LoggingMixin

在 Edge Worker 上排队、等待或运行的作业。

数据库中的每个元组表示并描述了一个作业的状态。

__tablename__ = 'edge_job'[来源]¶

dag_id[来源]¶

task_id[来源]¶

run_id[来源]¶

map_index[来源]¶

try_number[来源]¶

state[来源]¶

queue[来源]¶

concurrency_slots[来源]¶

command[来源]¶

queued_dttm[来源]¶

edge_worker[来源]¶

last_update[来源]¶

__table_args__[来源]¶

属性 key[来源]¶

属性 last_update_t: float[来源]¶