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]

此條目有幫助嗎?