fix

chiajunglien · chiajunglien · commit 5d0778880589 · 2026-06-15T03:15:01.000Z
diff --git a/dags/tpu_observability/utils/jobset_util.py b/dags/tpu_observability/utils/jobset_util.py
@@ -1073,6 +1073,8 @@ def verify_recovery_duration(start_time: TimeUtil, end_time: TimeUtil):
         "The 'jobset_time_to_recover' metric requires > 60s to be recorded. "
         "Failing fast to avoid waiting for a missing metric."
     )
+
+
 @task.sensor(poke_interval=60, timeout=3600, mode="poke")
 def wait_for_jobset_metrics(
     metric_name: JobSetHealthiness,

Original file line number	Diff line number	Diff line change
`@@ -1073,6 +1073,8 @@ def verify_recovery_duration(start_time: TimeUtil, end_time: TimeUtil):`
`1073`	`1073`	`"The 'jobset_time_to_recover' metric requires > 60s to be recorded. "`
`1074`	`1074`	`"Failing fast to avoid waiting for a missing metric."`
`1075`	`1075`	`)`
	`1076`	`+`
	`1077`	`+`
`1076`	`1078`	`@task.sensor(poke_interval=60, timeout=3600, mode="poke")`
`1077`	`1079`	`def wait_for_jobset_metrics(`
`1078`	`1080`	`metric_name: JobSetHealthiness,`