`airflow.providers.plexus.operators.job`¶

模組內容¶

類別¶

PlexusJobOperator

提交 Plexus 任務。

屬性¶

airflow.providers.plexus.operators.job.logger[原始碼]¶

class airflow.providers.plexus.operators.job.PlexusJobOperator(job_params, **kwargs)[原始碼]¶

繼承自： airflow.models.BaseOperator

提交 Plexus 任務。

參數: job_params (dict) – 啟動任務所需的參數。

必要的任務參數如下

“name”：使用者建立的任務名稱。
“app”：要執行的應用程式名稱。可在 Plexus UI 中找到。
“queue”：公開叢集名稱。可在 Plexus UI 中找到。
“num_nodes”：節點數量。
“num_cores”：每個節點的核心數。

execute(context)[原始碼]¶

在建立運算子時衍生。

上下文與渲染 Jinja 模板時使用的字典相同。

請參考 get_template_context 以獲得更多上下文資訊。

construct_job_params(hook)[原始碼]¶

建立 job_params 字典，用於 API 呼叫以啟動 Plexus 任務。

啟動任務所需的一些參數在 Plexus UI 中對使用者不可用。例如，需要應用程式 ID，但在 UI 中僅提供應用程式名稱。此函數的作用是使用使用者提供的值，在後端查找所需的參數值。

參數: hook (Any) – plexus hook 物件

這個條目有幫助嗎？