Skip to content

Commit 802a842

Browse files
committed
address comment 3
Signed-off-by: Milind Waykole <mwaykole@redhat.com>
1 parent fa54879 commit 802a842

File tree

2 files changed

+6
-8
lines changed

2 files changed

+6
-8
lines changed

tests/model_serving/model_server/keda/utils.py

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -4,25 +4,24 @@
44
from kubernetes.dynamic.exceptions import ResourceNotFoundError
55

66

7-
def get_isvc_keda_scaledobject(client: DynamicClient, isvc: InferenceService) -> list[ScaledObject]:
7+
def get_isvc_keda_scaledobject(client: DynamicClient, isvc: InferenceService) -> ScaledObject:
88
"""
9-
Get KEDA ScaledObject resources associated with an InferenceService.
9+
Get KEDA ScaledObject resource associated with an InferenceService.
1010
1111
Args:
1212
client (DynamicClient): OCP Client to use.
1313
isvc (InferenceService): InferenceService object.
1414
1515
Returns:
16-
list[ScaledObject]: A list containing the ScaledObject
16+
ScaledObject: The ScaledObject for the InferenceService
1717
1818
Raises:
19-
ResourceNotFoundError: if no ScaledObjects are found.
19+
ResourceNotFoundError: if the ScaledObject is not found.
2020
"""
2121
namespace = isvc.namespace
2222
scaled_object_name = isvc.name + "-predictor"
2323

2424
try:
25-
scaled_object = ScaledObject(client=client, name=scaled_object_name, namespace=namespace, ensure_exists=True)
26-
return [scaled_object]
25+
return ScaledObject(client=client, name=scaled_object_name, namespace=namespace, ensure_exists=True)
2726
except Exception as e:
2827
raise ResourceNotFoundError(f"{isvc.name} has no KEDA ScaledObjects: {e}")

tests/model_serving/model_server/utils.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -248,8 +248,7 @@ def verify_keda_scaledobject(
248248
expected_query: Expected query string
249249
expected_threshold: Expected threshold as string (e.g. "50.000000")
250250
"""
251-
scaled_objects = get_isvc_keda_scaledobject(client=client, isvc=isvc)
252-
scaled_object = scaled_objects[0]
251+
scaled_object = get_isvc_keda_scaledobject(client=client, isvc=isvc)
253252
trigger_meta = scaled_object.instance.spec.triggers[0].metadata
254253
trigger_type = scaled_object.instance.spec.triggers[0].type
255254
query = trigger_meta.get("query")

0 commit comments

Comments
 (0)