airflow.providers.edge3.models.edge_job¶

Classes¶

EdgeJobModel

A job which is queued, waiting or running on a Edge Worker.

Module Contents¶

class 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)[source]¶

Bases: airflow.models.base.Base, airflow.utils.log.logging_mixin.LoggingMixin

A job which is queued, waiting or running on a Edge Worker.

Each tuple in the database represents and describes the state of one job.

__tablename__ = 'edge_job'[source]¶

dag_id[source]¶

task_id[source]¶

run_id[source]¶

map_index[source]¶

try_number[source]¶

state[source]¶

queue[source]¶

concurrency_slots[source]¶

command[source]¶

queued_dttm[source]¶

edge_worker[source]¶

last_update[source]¶

__table_args__[source]¶

property key[source]¶

property last_update_t: float[source]¶