main:
    params: [input]
    steps:
    - クエリ実行:
        try:
            steps:
                - クエリ実行ログ:
                    call: sys.log
                    args:
                      text: "クエリを実行します。"
                      severity: INFO
                - executeQuery:
                    call: googleapis.bigquery.v2.jobs.insert
                    args:
                        projectId: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
                        body:
                            configuration:
                                query:
                                    query: ${input.testQuery}
                                    useLegacySql: false
        retry:
            predicate: ${retry_decision}
            max_retries: 5
            backoff:
                initial_delay: 30
                max_delay: 300
                multiplier: 2
        except:
            as: e
            steps:
                - エラーログ:
                    call: sys.log
                    args:
                      text: クエリの実行でエラーが発生しました。
                      severity: ERROR
                - エラー内容ログ出力:
                    call: sys.log
                    args:
                      text: ${e}
                      severity: ERROR
                - raiseError:
                    raise: "Query execution error"
retry_decision:
  params: [e]
  steps:
    - do_repeat:
        return: true

retry_decision:
  params: [e]
  steps:
    - what_to_repeat:
        switch:
          # HTTPステータスコードが500の場合はリトライする
          - condition: ${e.code == 500}
            return: true
    - otherwise:
        return: false

"status":{"errorResult":{"location":"query","message":"Unrecognized name: not_exist_column at [1:8]","reason":"invalidQuery"},
"errors":[{"location":"query","message":"Unrecognized name: not_exist_column at [1:8]","reason":"invalidQuery"}],"state":"DONE"}