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

管理 Kubernetes Kueue。

类¶

`KubernetesInstallKueueOperator`	安装 Kubernetes Kueue。
`KubernetesStartKueueJobOperator`	在 Kueue 中执行 Kubernetes Job。

模块内容¶

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

基类: airflow.models.BaseOperator

安装 Kubernetes Kueue。

另请参阅

有关如何使用此 operator 的更多信息，请参阅指南: KubernetesInstallKueueOperator

参数:

kueue_version (str) – 要安装的 Kubernetes Kueue 版本。
kubernetes_conn_id (str) – 用于 Kubernetes 集群的 kubernetes 连接 ID。

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

kubernetes_conn_id = 'kubernetes_default'[source]¶

kueue_version[source]¶

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

execute(context)[source]¶

创建 operator 时派生。

Context 与渲染 jinja 模板时使用的字典相同。

有关更多 context，请参阅 get_template_context。

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

基类: airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator

在 Kueue 中执行 Kubernetes Job。

另请参阅

有关如何使用此 operator 的更多信息，请参阅指南: KubernetesStartKueueJobOperator

参数:: queue_name (str) – 集群中的 Queue 名称

template_fields[source]¶

queue_name[source]¶

suspend: bool[source]¶