airflow.providers.edge3.models.edge_job¶

Classes¶

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

Functions¶

build_job_key(dag_id, task_id, run_id, try_number, ...)

Build the key the executor layer uses for a job row.

Module Contents¶

airflow.providers.edge3.models.edge_job.build_job_key(dag_id, task_id, run_id, try_number, map_index)[source]¶

Build the key the executor layer uses for a job row.

A row is a callback only if it has the full identity queue_workload() writes for callbacks, since ExecuteCallback is a valid Dag id. A task row maps to the airflow.models TaskInstanceKey, not the airflow.sdk one, because BaseExecutor dispatches on it with isinstance.

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, team_name=None)[source]¶

Bases: airflow.providers.edge3.models.edge_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]¶

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

__table_args__[source]¶

property key: airflow.models.taskinstancekey.TaskInstanceKey | airflow.models.callback.CallbackKey[source]¶

Key of the job as the executor layer knows it.

property last_update_t: float[source]¶

Was this entry helpful?