Argo Workflows 中的输出参数无法使用 jsonpath 函数
回答问题
我有一个工作流程,其中我使用jsonpath函数作为输出参数以从 json 字符串中提取特定值,但它失败并出现此错误Error (exit code 255)
这是我的工作流程
apiVersion: argoproj.io/v1alpha1
kind: Workflow
metadata:
generateName: wf-dev-
spec:
entrypoint: main
templates:
- name: main
dag:
tasks:
- name: dev-create
templateRef:
name: dev-create-wft
template: main
arguments:
parameters:
- name: param1
value: "val1"
- name: dev-outputs
depends: dev-create.Succeeded
templateRef:
name: dev-outputs-wft
template: main
arguments:
parameters:
- name: devoutputs
value: "{{=jsonpath(tasks.dev-create.outputs.parameters.devoutputs, '$.alias.value')}}"
在上述工作流任务dev-create调用另一个 workflowTemplatedev-create-wft返回另一个 workflowTemplate 的输出
这是我的工作流程模板
apiVersion: argoproj.io/v1alpha1
kind: WorkflowTemplate
metadata:
name: dev-create-wft
spec:
entrypoint: main
templates:
- name: main
outputs:
parameters:
- name: devoutputs
valueFrom:
expression: "tasks['dev1'].outputs.parameters.devoutputs"
inputs:
parameters:
- name: param1
dag:
tasks:
- name: dev1
templateRef:
name: fnl-dev
template: main
arguments:
parameters:
- name: param1
value: "{{inputs.parameters.param1}}"
返回的 json 输出如下所示
{
"alias": {
"value": "testing:dev1infra",
"type": "string",
"sensitive": false
},
"match": {
"value": "dev1infra-testing",
"type": "string",
"sensitive": false
}
}
工作流是否支持jsonpath功能?我问的原因是,当我在另一个工作流模板dev-outputs-wft中使用相同的功能时它正在工作
可能是什么问题?
Answers
当表达式无法计算时,Argo Workflows 不会用其计算值替换表达式。 Argo Workflows 传递表达式_就像它是参数_一样。
Argo Workflows 中的{{=}}“表达式标签模板”必须根据expr 语言规范编写。
在简单的标签模板中,Argo Workflows 自己进行解释。所以参数名称中的连字符是允许的。例如,Argo Workflows 将value: "{{inputs.parameters.what-it-is}}"评估为value: "over 9000!"。
但在表达式标记模板中,expr 将连字符解释为减号运算符。所以value: "{{=inputs.parameters.what-it-is}}"看起来像一个非常奇怪的数学表达式,失败了,并且没有被替换。解决方法是使用['what-it-is']访问相应的地图项。
我的猜测是您的表达式失败了,Argo Workflows 将表达式传递给dev-outputs-wft未被替换,并且接收该参数的任何 shell 脚本都在中断。
如果我是对的,修复很容易:
- name: dev-outputs
depends: dev-create.Succeeded
templateRef:
name: dev-outputs-wft
template: main
arguments:
parameters:
- name: devoutputs
- value: "{{=jsonpath(tasks.dev-create.outputs.parameters.devoutputs, '$.alias.value')}}"
+ value: "{{=jsonpath(tasks['dev-create'].outputs.parameters.devoutputs, '$.alias.value')}}"
更多推荐
所有评论(0)