Skip to content

Commit 4abb7b8

Browse files
committed
fix
1 parent e190a7f commit 4abb7b8

1 file changed

Lines changed: 0 additions & 5 deletions

File tree

dags/tpu_observability/utils/jobset_util.py

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -525,15 +525,10 @@ def wait_for_jobset_started(
525525
return all(p > threshold_value for p in last_n_data_points)
526526

527527

528-
<<<<<<< HEAD
529-
@task.sensor(poke_interval=60, timeout=3600, mode="reschedule")
530-
def wait_for_jobset_ttr_to_be_found(node_pool: node_pool_info) -> bool:
531-
=======
532528
@task.sensor(poke_interval=60, timeout=3600, mode="poke")
533529
def wait_for_jobset_ttr_to_be_found(
534530
node_pool: node_pool_info, jobset_name: str
535531
) -> bool:
536-
>>>>>>> 03535a3 (feat: add jobset_ttr_pod_oom DAG for v6e recovery validation)
537532
"""
538533
Polls the jobset time_between_interruptions metric.
539534

0 commit comments

Comments
 (0)