fix: Specify owner of task fetch_interruption_log_records (GoogleCloudPlatform#1132)

yuna-tzeng · web-flow · commit b02c38e12eae · 2026-01-14T16:38:16.000+08:00
diff --git a/dags/tpu_observability/interruption_validation_dag.py b/dags/tpu_observability/interruption_validation_dag.py
@@ -554,7 +554,9 @@ def fetch_interruption_metric_records_task(
                 configs,
                 proper_time_range,
             )
-            log_records = fetch_interruption_log_records(
+            log_records = fetch_interruption_log_records.override(
+                owner=test_owner.QUINN_M
+            )(
                 configs,
                 proper_time_range,
             )

Original file line number	Diff line number	Diff line change
`@@ -554,7 +554,9 @@ def fetch_interruption_metric_records_task(`
`554`	`554`	`configs,`
`555`	`555`	`proper_time_range,`
`556`	`556`	`)`
`557`		`- log_records = fetch_interruption_log_records(`
	`557`	`+ log_records = fetch_interruption_log_records.override(`
	`558`	`+ owner=test_owner.QUINN_M`
	`559`	`+ )(`
`558`	`560`	`configs,`
`559`	`561`	`proper_time_range,`
`560`	`562`	`)`