fix: Remove timeout parameter from wait_for_job_start task in tpu-info DAG

chengpinglin · chengpinglin · commit dcad8339bf7a · 2026-01-14T10:46:10.000+08:00
diff --git a/dags/tpu_observability/tpu_info_cli_validation_dags.py b/dags/tpu_observability/tpu_info_cli_validation_dags.py
@@ -187,7 +187,7 @@ def validate_process(info, pod_name: str) -> str:
       )
 
       wait_for_job_start = jobset.wait_for_jobset_started.override(
-          task_id="wait_for_job_start", timeout=1200
+          task_id="wait_for_job_start"
       )(cluster_info, pod_name_list=pod_names, job_apply_time=apply_time)
 
       # Keyword arguments are generated dynamically at runtime (pylint does not

Original file line number	Diff line number	Diff line change
`@@ -187,7 +187,7 @@ def validate_process(info, pod_name: str) -> str:`
`187`	`187`	`)`
`188`	`188`
`189`	`189`	`wait_for_job_start = jobset.wait_for_jobset_started.override(`
`190`		`- task_id="wait_for_job_start", timeout=1200`
	`190`	`+ task_id="wait_for_job_start"`
`191`	`191`	`)(cluster_info, pod_name_list=pod_names, job_apply_time=apply_time)`
`192`	`192`
`193`	`193`	`# Keyword arguments are generated dynamically at runtime (pylint does not`