Google Cloud Workflows触发Cloud Run Job超时及异步处理咨询

1. 触发Cloud Run Job后立即退出，无需等待 #

在Workflow YAML中调用Cloud Run Jobs的运行API时，直接指定不等待Job执行完成即可。核心是使用googleapis.run.v1.namespaces.jobs.run内置方法，触发后直接返回，不阻塞Workflow执行。

示例YAML代码：

main:
  steps:
    - trigger_job:
        call: googleapis.run.v1.namespaces.jobs.run
        args:
          parent: "projects/[你的项目ID]/locations/[你的区域]"
          jobId: "[你的Cloud Run Job名称]"
          # 可选：覆盖Job默认配置，比如资源限制
          body:
            overrides:
              containerOverrides:
                - name: "[容器名称]"
                  resources:
                    limits:
                      cpu: "1"
                      memory: "2Gi"
        result: job_run_response
    - exit_workflow:
        return: "Cloud Run Job已触发，Workflow结束"

触发后Workflow会立刻退出，不会等待Job执行完成，自然不会出现30分钟超时问题。

2. 持续检查Cloud Run Job状态直到完成 #

先触发Job并获取运行实例ID，之后循环调用状态查询API，每次间隔固定时间休眠，直到Job状态变为成功或失败。

示例YAML代码：

main:
  steps:
    - trigger_job:
        call: googleapis.run.v1.namespaces.jobs.run
        args:
          parent: "projects/[你的项目ID]/locations/[你的区域]"
          jobId: "[你的Cloud Run Job名称]"
        result: job_run_response
    - extract_execution_id:
        assign:
          - execution_id: ${job_run_response.metadata.name}
          - job_status: "PENDING"
    - status_check_loop:
        while:
          condition: ${not(job_status in ["SUCCEEDED", "FAILED"])}
          steps:
            - fetch_execution_details:
                call: googleapis.run.v1.namespaces.jobs.executions.get
                args:
                  name: "projects/[你的项目ID]/locations/[你的区域]/jobs/[你的Cloud Run Job名称]/executions/${execution_id}"
                result: execution_data
            - update_status:
                assign:
                  - job_status: ${execution_data.status.conditions[0].type}
            - wait_for_next_check:
                call: sys.sleep
                args:
                  seconds: 300  # 每5分钟检查一次，可按需调整
            - log_current_status:
                call: sys.log
                args:
                  text: "Job当前状态：${job_status}，继续等待..."
                  severity: "INFO"
    - finish_workflow:
        return: "Cloud Run Job执行完成，最终状态：${job_status}"

注意事项 #

• 需调整Workflow的超时时间（比如设置为2小时），避免Workflow自身因等待过长超时。
• 确保Workflow的服务账号拥有run.jobs.run和run.jobs.executions.get的权限。

内容的提问来源于stack exchange，提问作者Parthiban Nagarajan