| :mod:`airflow.models.kubernetes` |
| ================================ |
| |
| .. py:module:: airflow.models.kubernetes |
| |
| |
| Module Contents |
| --------------- |
| |
| .. py:class:: KubeResourceVersion |
| |
| Bases: :class:`airflow.models.base.Base` |
| |
| .. attribute:: __tablename__ |
| :annotation: = kube_resource_version |
| |
| |
| |
| .. attribute:: one_row_id |
| |
| |
| |
| |
| .. attribute:: resource_version |
| |
| |
| |
| |
| |
| .. staticmethod:: get_current_resource_version(session=None) |
| |
| |
| |
| |
| .. staticmethod:: checkpoint_resource_version(resource_version, session=None) |
| |
| |
| |
| |
| .. staticmethod:: reset_resource_version(session=None) |
| |
| |
| |
| |
| .. py:class:: KubeWorkerIdentifier |
| |
| Bases: :class:`airflow.models.base.Base` |
| |
| .. attribute:: __tablename__ |
| :annotation: = kube_worker_uuid |
| |
| |
| |
| .. attribute:: one_row_id |
| |
| |
| |
| |
| .. attribute:: worker_uuid |
| |
| |
| |
| |
| |
| .. staticmethod:: get_or_create_current_kube_worker_uuid(session=None) |
| |
| |
| |
| |
| .. staticmethod:: checkpoint_kube_worker_uuid(worker_uuid, session=None) |
| |
| |
| |
| |
