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: sqlalchemy.orm.Mapped[str][source]¶

task_id: sqlalchemy.orm.Mapped[str][source]¶

run_id: sqlalchemy.orm.Mapped[str][source]¶

map_index: sqlalchemy.orm.Mapped[int][source]¶

try_number: sqlalchemy.orm.Mapped[int][source]¶

state: sqlalchemy.orm.Mapped[str][source]¶

queue: sqlalchemy.orm.Mapped[str][source]¶

concurrency_slots: sqlalchemy.orm.Mapped[int][source]¶

command: sqlalchemy.orm.Mapped[str][source]¶

queued_dttm: sqlalchemy.orm.Mapped[datetime.datetime | None][source]¶

edge_worker: sqlalchemy.orm.Mapped[str | None][source]¶

last_update: sqlalchemy.orm.Mapped[datetime.datetime | None][source]¶

__table_args__[source]¶

property key[source]¶

property last_update_t: float[source]¶