如何在 Argo 工作流程中增加计数器？答案

【问题标题】：how to increment a counter in Argo workflow?如何在 Argo 工作流程中增加计数器？
【发布时间】：2022-01-06 18:48:42
【问题描述】：

我写了一个 argo dag 以递归方式触发 spark 作业，直到条件满足。我有一个计数器参数，每次成功完成 spark 作业后都需要增加 1。但这并没有发生。这是我的工作流程的 sn-p。

  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

【问题讨论】：

value: "{{=asInt(workflow.parameters.counter)}}+1" 我试过了，但结果是 "1+1" 而不是 2

标签： apache-spark kubernetes pyspark argo-workflows argo

【解决方案1】：

+1 应该是表达式的一部分。试试：

arguments:
  parameters:
    - name: value
      value: "{{=asInt(workflow.parameters.counter) + 1}}"

【讨论】：