我已经编写了一个argo-dag来触发递归中的spark作业,直到条件满足。我有一个计数器参数,每次成功完成火花作业后,需要增加1。但这并没有发生。以下是我的工作流程片段。
templates:
- name: test-dag
dag:
tasks:
- name: test-spark-job
template: test-spark-job
- name: loop-it
template: backfill-dag
dependencies: [backfill-spark-job]
when: "{{=asInt(workflow.parameters.counter)}} <= {{=asInt(workflow.parameters.batchsize)}}"
arguments:
parameters:
- name: counter
value: {{=asInt(workflow.parameters.counter)}}+1
It+1
应该是表达式的一部分。尝试:
arguments:
parameters:
- name: value
value: "{{=asInt(workflow.parameters.counter) + 1}}"