airflow.providers.cncf.kubernetes.operators.kueue¶

Manage a Kubernetes Kueue.

Classes¶

`KubernetesInstallKueueOperator`	Installs a Kubernetes Kueue.
`KubernetesStartKueueJobOperator`	Executes a Kubernetes Job in Kueue.

Module Contents¶

class airflow.providers.cncf.kubernetes.operators.kueue.KubernetesInstallKueueOperator(kueue_version, kubernetes_conn_id='kubernetes_default', *args, **kwargs)[source]¶

Bases: airflow.providers.cncf.kubernetes.version_compat.BaseOperator

Installs a Kubernetes Kueue.

See also

For more information on how to use this operator, take a look at the guide: KubernetesInstallKueueOperator

Parameters:

kueue_version (str) – The Kubernetes Kueue version to install.
kubernetes_conn_id (str) – The kubernetes connection id for the Kubernetes cluster.

template_fields: collections.abc.Sequence[str] = ('kueue_version', 'kubernetes_conn_id')[source]¶

kubernetes_conn_id = 'kubernetes_default'[source]¶

kueue_version[source]¶

property hook: airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook[source]¶

execute(context)[source]¶

Derive when creating an operator.

The main method to execute the task. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

class airflow.providers.cncf.kubernetes.operators.kueue.KubernetesStartKueueJobOperator(queue_name, *args, **kwargs)[source]¶

Bases: airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator

Executes a Kubernetes Job in Kueue.