弱点補強: Argo Workflows DAGテンプレート設計×リトライ戦略×Artifact受け渡し — stepsで依存関係のない処理まで直列実行→dagテンプレート+dependenciesで並列化 × retryStrategy皆無で一時的な429エラーも即失敗→OnTransientError+指数バックオフ × GCSパスの文字列連結→Argo Artifactsで宣言的受け渡し × SAキーファイルのSecretマウント→Workload Identity Federationで鍵レス化 × onExit未設定で失敗に1日気づけなかった事故→exitHandlerで成功/失敗いずれも必達通知（MOps 販促システムチーム campaign-performance-daily GKE Autopilot/Argo Workflows 3.5系 Bad→Good 7点）

問題は4層に分類できる。(1) 実行グラフの誤り — steps（配列の配列＝直列のブロック、内側の配列は並列）を使っているが、実質すべてのステップが1つずつのブロックになっており、依存関係のないextract-ordersとextract-couponsまで直列化されている。dagテンプレートでdependenciesを宣言すればスケジューラが自動的に並列実行してくれる。(2) 失敗の扱いが「全か無か」になっている — リトライが一切ないため一時的な障害でも即失敗し、かつ失敗時にexitHandlerが無いため誰にも気づかれない。(3) データ受け渡しが「命名規約という名の口約束」になっている — GCSパスを文字列で毎回組み立てており、Argo自身がこのファイルの生成・消費関係を認識できていない。(4) 認証情報の運用がCLAUDE.mdのセキュリティ原則に反する — 長期鍵をSecretとしてマウントしている。

「このワークフローが3ヶ月後、深夜2時にBigQueryの一時障害で失敗したとき、誰が・どうやって気づくか？」を自問すると、指摘の半分（リトライ・exitHandler）が自然に出てくる。

• 問題①: stepsで直列実行 → dagテンプレートに変更し、extract-orders/extract-couponsは共通の依存元（バリデーションstep）にのみ依存させ、両者の間には依存関係を張らない
• 問題②: リトライなし → 各templateにretryStrategyを設定し、retryPolicy: OnTransientError＋backoff（指数バックオフ）＋limit（上限回数）を組み合わせる
• 問題③: GCSパスのハードコード → outputs.artifacts/inputs.artifactsを使い、各templateはローカルパスだけを意識すればArgoが裏側でアップロード/ダウンロードを自動化してくれる形にする
• 問題④: SAキーファイルのマウント → volumes/GOOGLE_APPLICATION_CREDENTIALSを削除し、PodにserviceAccountNameでWorkload Identityバインド済みKSAを指定する
• 問題⑤: タイムアウトなし → 各templateにactiveDeadlineSecondsを設定する
• 問題⑥: 失敗時に気づけない → spec.onExitにnotify-exitテンプレートを指定する。{{workflow.status}}を参照でき、成功・失敗どちらでも必ず実行される
• 問題⑦: target-dateの未検証 → DAGの先頭ノードとしてvalidate-dateテンプレートを置き、他の全ステップがこれに依存する形にする

apiVersion: argoproj.io/v1alpha1
kind: WorkflowTemplate
metadata:
  name: campaign-performance-daily
spec:
  entrypoint: main
  onExit: notify-exit                        # 成功/失敗いずれでも必ず呼ばれる
  serviceAccountName: campaign-pipeline-ksa   # Workload Identityでバインド済みKSA、鍵ファイル不要
  arguments:
    parameters:
      - name: target-date

  templates:
    - name: main
      dag:
        tasks:
          - name: validate-date
            template: validate-date
          - name: extract-orders
            template: extract-orders
            dependencies: [validate-date]
          - name: extract-coupons
            template: extract-coupons
            dependencies: [validate-date]     # extract-ordersとは依存しない→並列実行される
          - name: transform
            template: transform
            dependencies: [extract-orders, extract-coupons]
            arguments:
              artifacts:
                - name: orders
                  from: "{{tasks.extract-orders.outputs.artifacts.orders-parquet}}"
                - name: coupons
                  from: "{{tasks.extract-coupons.outputs.artifacts.coupons-parquet}}"
          - name: load
            template: load
            dependencies: [transform]
            arguments:
              artifacts:
                - name: mart
                  from: "{{tasks.transform.outputs.artifacts.mart-parquet}}"

    - name: extract-orders
      outputs:
        artifacts:
          - name: orders-parquet
            path: /work/orders.parquet   # Argoが自動でArtifact Repositoryへアップロード
      retryStrategy:
        limit: 3
        retryPolicy: OnTransientError
        backoff: { duration: 30s, factor: 2, maxDuration: 5m }
      activeDeadlineSeconds: 900
      # container定義（image, command, args, resources）は省略

    - name: notify-exit
      container:
        image: curlimages/curl:8.7.1
        command: [sh, -c]
        args:
          - >
            STATUS="{{workflow.status}}";
            curl -sf -X POST -H 'Content-Type: application/json'
            -d "{\"text\":\"campaign-performance-daily [$STATUS]\"}"
            "$SLACK_WEBHOOK_URL"
        envFrom:
          - secretRef:
              name: slack-webhook   # Webhook URLはコード直書きせずSecretから注入