Skip to content

Commit bfcfae0

Browse files
committed
add unit test for js evaluator tagging
1 parent fd1cc3f commit bfcfae0

File tree

1 file changed

+31
-1
lines changed

1 file changed

+31
-1
lines changed

sagemaker-train/tests/unit/train/evaluate/test_execution.py

Lines changed: 31 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -299,7 +299,37 @@ def test_create_pipeline_when_not_found(self, mock_pipeline_class, mock_create,
299299
DEFAULT_ROLE,
300300
DEFAULT_PIPELINE_DEFINITION,
301301
mock_session,
302-
DEFAULT_REGION
302+
DEFAULT_REGION,
303+
[]
304+
)
305+
assert result == mock_pipeline
306+
307+
@patch("sagemaker.train.evaluate.execution._create_evaluation_pipeline")
308+
@patch("sagemaker.train.evaluate.execution.Pipeline")
309+
def test_create_pipeline_when_not_found_with_jumpstart_tags(self, mock_pipeline_class, mock_create, mock_session):
310+
"""Test creating pipeline when it doesn't exist."""
311+
error_response = {"Error": {"Code": "ResourceNotFound"}}
312+
mock_pipeline_class.get.side_effect = ClientError(error_response, "DescribePipeline")
313+
mock_pipeline = MagicMock()
314+
mock_create.return_value = mock_pipeline
315+
create_tags = [{"key": "sagemaker-sdk:jumpstart-model-id", "value": "dummy-js-model-id"}]
316+
317+
result = _get_or_create_pipeline(
318+
eval_type=EvalType.BENCHMARK,
319+
pipeline_definition=DEFAULT_PIPELINE_DEFINITION,
320+
role_arn=DEFAULT_ROLE,
321+
session=mock_session,
322+
region=DEFAULT_REGION,
323+
create_tags=create_tags
324+
)
325+
326+
mock_create.assert_called_once_with(
327+
EvalType.BENCHMARK,
328+
DEFAULT_ROLE,
329+
DEFAULT_PIPELINE_DEFINITION,
330+
mock_session,
331+
DEFAULT_REGION,
332+
create_tags
303333
)
304334
assert result == mock_pipeline
305335

0 commit comments

Comments
 (0)