airflow.providers.edge.models.edge_job

Module Contents

Classes

EdgeJobModel

A job which is queued, waiting or running on a Edge Worker.
class airflow.providers.edge.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.

property key[source]
property last_update_t: float[source]
__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]

Was this entry helpful?