`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)[源代码]¶

创建用于 API 调用以启动 Plexus 作业的 job_params 字典。

Plexus UI 中用户无法使用一些启动作业所需的参数。例如，需要应用程序 ID，但 UI 中仅提供了应用程序名称。此函数充当使用用户提供的值后端查找所需参数值。

参数: hook (Any) – plexus hook 对象

此条目是否有帮助？