airflow.providers.cncf.kubernetes.operators.kueue

Manage a Kubernetes Kueue.

Module Contents

Classes

KubernetesInstallKueueOperator

Installs a Kubernetes Kueue.

KubernetesStartKueueJobOperator

Executes a Kubernetes Job in Kueue.
class airflow.providers.cncf.kubernetes.operators.kueue.KubernetesInstallKueueOperator(kueue_version, kubernetes_conn_id='kubernetes_default', *args, **kwargs)[source]

Bases: airflow.models.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]
hook()[source]
execute(context)[source]

Derive when creating an operator.

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.

See also

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

Parameters

queue_name (str) – The name of the Queue in the cluster

template_fields[source]

Was this entry helpful?