`airflow.models.kubernetes`¶

Module Contents¶

class airflow.models.kubernetes.KubeResourceVersion[source]¶

Bases: airflow.models.base.Base

__tablename__ = kube_resource_version[source]¶

one_row_id[source]¶

resource_version[source]¶

static get_current_resource_version(session=None)[source]¶

static checkpoint_resource_version(resource_version, session=None)[source]¶

static reset_resource_version(session=None)[source]¶

class airflow.models.kubernetes.KubeWorkerIdentifier[source]¶

Bases: airflow.models.base.Base

__tablename__ = kube_worker_uuid[source]¶

one_row_id[source]¶

worker_uuid[source]¶

static get_or_create_current_kube_worker_uuid(session=None)[source]¶

static checkpoint_kube_worker_uuid(worker_uuid, session=None)[source]¶

Was this entry helpful?