File tree Expand file tree Collapse file tree
dags/tpu_observability/utils Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1025,13 +1025,10 @@ def wait_for_jobset_metrics(
10251025 Args:
10261026 metric_name (JobSetHealthiness): The status of the replicated job to
10271027 monitor.
1028- expected_value (any): The target value to wait for. If set to
1029- "USE_CONFIG_REPLICAS", the sensor will dynamically retrieve the
1030- expected count from the jobset_config.
1028+ expected_value (int): The target value to wait for.
10311029 node_pool (Info): An instance of the Info class containing GKE cluster
10321030 metadata.
1033- jobset_config (JobSet): An instance of the JobSet class representing
1034- the target jobset configuration.
1031+ jobset_name: The name of the JobSet.
10351032 start_time (TimeUtil, optional): The UTC timestamp to start polling
10361033 from. If not provided, defaults to 60 minutes before the current time.
10371034
You can’t perform that action at this time.
0 commit comments