我正在通过气流 DAG 在 GCP 中触发云运行作业。该作业需要 30 分钟才能执行,但请求超时为 900 秒,因此 DAG 任务失败。 错误是:
“操作未在指定的 900 秒超时内完成”。
900 秒似乎是 API 调用的默认超时时间。 云运行作业仍继续执行并成功完成 - 但 API 请求超时。如何设置API请求的超时时间(而不是云运行作业的超时时间)? 我用来触发云运行作业的代码片段:
def run_cloudrun_job(**kwargs):
client = run_v2.JobsClient()
request = run_v2.RunJobRequest(
name=f"projects/project_id/locations/region/jobs/job_name",
overrides=overrides,
)
operation = client.run_job(request=request)
response = operation.result()
您最多可以将 Cloud Run 超时设置为 3600 秒