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?