Skip to content

Commit

Permalink
Fixed unpatched object storage url bug in unit test.
Browse files Browse the repository at this point in the history
  • Loading branch information
lu-ohai committed Sep 20, 2023
1 parent edca7d8 commit 95fe7fa
Show file tree
Hide file tree
Showing 8 changed files with 172 additions and 18 deletions.
1 change: 1 addition & 0 deletions ads/model/deployment/model_deployment_infrastructure.py
Original file line number Diff line number Diff line change
Expand Up @@ -223,6 +223,7 @@ def _load_default_properties(self) -> Dict:
defaults[self.CONST_REPLICA] = DEFAULT_REPLICA

if NB_SESSION_OCID:
nb_session = None
try:
nb_session = DSCNotebookSession.from_ocid(NB_SESSION_OCID)
except Exception as e:
Expand Down
15 changes: 14 additions & 1 deletion tests/unitary/with_extras/model/test_artifact.py
Original file line number Diff line number Diff line change
Expand Up @@ -138,10 +138,23 @@ def test_prepare_runtime_yaml_inference_training(
(TrainingEnvInfo, mlcpu_path_cust, None, None, training_info_cust),
],
)
@patch("ads.model.runtime.env_info.get_service_packs")
def test__populate_env_info_inference(
self, env_info_class, conda_pack, bucketname, namespace, expected_env_info
self, mock_get_service_packs, env_info_class, conda_pack, bucketname, namespace, expected_env_info
):
"""test _populate_env_info."""
env_path = (
expected_env_info.inference_env_path if isinstance(expected_env_info, InferenceEnvInfo)
else expected_env_info.training_env_path
)
mock_get_service_packs.return_value = (
{
env_path : ("mlcpuv1", "3.6")
},
{
"mlcpuv1" : (env_path, "3.6")
}
)
env_info = self.artifact._populate_env_info(
env_info_class,
conda_pack=conda_pack,
Expand Down
22 changes: 20 additions & 2 deletions tests/unitary/with_extras/model/test_env_info.py
Original file line number Diff line number Diff line change
Expand Up @@ -177,7 +177,16 @@ def test_from_slug_prod_sp(self):
info.training_env_type = "service_pack"
info.training_python_version = "3.6"

def test_from_slug_not_exist(self):
@patch("ads.model.runtime.env_info.get_service_packs")
def test_from_slug_not_exist(self, mock_get_service_packs):
mock_get_service_packs.return_value = (
{
"test_path" : ("mlcpuv1", "3.6"),
},
{
"mlcpuv1" : ("test_path", "3.6"),
}
)
with pytest.warns(UserWarning, match="not a service pack"):
TrainingEnvInfo.from_slug(
"not_exist", namespace="ociodscdev", bucketname="service-conda-packs"
Expand Down Expand Up @@ -256,7 +265,16 @@ def test_from_slug_prod_sp(self):
info.inference_env_type = "service_pack"
info.inference_python_version = "3.6"

def test_from_slug_not_exist(self):
@patch("ads.model.runtime.env_info.get_service_packs")
def test_from_slug_not_exist(self, mock_get_service_packs):
mock_get_service_packs.return_value = (
{
"test_path" : ("mlcpuv1", "3.6"),
},
{
"mlcpuv1" : ("test_path", "3.6"),
}
)
with pytest.warns(UserWarning, match="not a service pack"):
InferenceEnvInfo.from_slug(
"not_exist", namespace="ociodscdev", bucketname="service-conda-packs"
Expand Down
51 changes: 44 additions & 7 deletions tests/unitary/with_extras/model/test_generic_model.py
Original file line number Diff line number Diff line change
Expand Up @@ -279,14 +279,29 @@ def test_prepare_fail(self, mock_handle_model_file_name):
"oci://service-conda-packs@ociodscdev/service_pack/cpu/General_Machine_Learning_for_CPUs/1.0/mlcpuv1"
)

@patch("ads.model.runtime.env_info.get_service_packs")
@patch("ads.common.auth.default_signer")
def test_prepare_both_conda_env(self, mock_signer):
def test_prepare_both_conda_env(self, mock_signer, mock_get_service_packs):
"""prepare a model by only providing inference conda env."""
inference_conda_env="oci://service-conda-packs@ociodscdev/service_pack/cpu/General_Machine_Learning_for_CPUs/1.0/mlcpuv1"
inference_python_version="3.6"
training_conda_env="oci://service-conda-packs@ociodscdev/service_pack/cpu/Oracle_Database_for_CPU_Python_3.7/1.0/database_p37_cpu_v1"
training_python_version="3.7"
mock_get_service_packs.return_value = (
{
inference_conda_env : ("mlcpuv1", inference_python_version),
training_conda_env : ("database_p37_cpu_v1", training_python_version)
},
{
"mlcpuv1" : (inference_conda_env, inference_python_version),
"database_p37_cpu_v1" : (training_conda_env, training_python_version)
}
)
self.generic_model.prepare(
inference_conda_env="oci://service-conda-packs@ociodscdev/service_pack/cpu/General_Machine_Learning_for_CPUs/1.0/mlcpuv1",
inference_python_version="3.6",
training_conda_env="oci://service-conda-packs@ociodscdev/service_pack/cpu/Oracle_Database_for_CPU_Python_3.7/1.0/database_p37_cpu_v1",
training_python_version="3.7",
inference_conda_env=inference_conda_env,
inference_python_version=inference_python_version,
training_conda_env=training_conda_env,
training_python_version=training_python_version,
model_file_name="fake_model_name",
force_overwrite=True,
)
Expand Down Expand Up @@ -349,8 +364,19 @@ def test_reload(self):

@patch.object(GenericModel, "_random_display_name", return_value="test_name")
@patch.object(DataScienceModel, "create")
def test_save(self, mock_dsc_model_create, mock__random_display_name):
@patch("ads.model.runtime.env_info.get_service_packs")
def test_save(self, mock_get_service_packs, mock_dsc_model_create, mock__random_display_name):
"""test saving a model to artifact."""
inference_conda_env="oci://service-conda-packs@ociodscdev/service_pack/cpu/Data_Exploration_and_Manipulation_for_CPU_Python_3.7/3.0/dataexpl_p37_cpu_v3"
inference_python_version="3.7"
mock_get_service_packs.return_value = (
{
inference_conda_env : ("dataexpl_p37_cpu_v3", inference_python_version),
},
{
"dataexpl_p37_cpu_v3" : (inference_conda_env, inference_python_version),
}
)
mock_dsc_model_create.return_value = MagicMock(id="fake_id")
self.generic_model.prepare(
inference_conda_env="dataexpl_p37_cpu_v3",
Expand All @@ -371,8 +397,19 @@ def test_save(self, mock_dsc_model_create, mock__random_display_name):
parallel_process_count=utils.DEFAULT_PARALLEL_PROCESS_COUNT,
)

def test_save_not_implemented_error(self):
@patch("ads.model.runtime.env_info.get_service_packs")
def test_save_not_implemented_error(self, mock_get_service_packs):
"""test saving a model to artifact."""
inference_conda_env="oci://service-conda-packs@ociodscdev/service_pack/cpu/Data_Exploration_and_Manipulation_for_CPU_Python_3.7/3.0/dataexpl_p37_cpu_v3"
inference_python_version="3.7"
mock_get_service_packs.return_value = (
{
inference_conda_env : ("dataexpl_p37_cpu_v3", inference_python_version),
},
{
"dataexpl_p37_cpu_v3" : (inference_conda_env, inference_python_version),
}
)
self.generic_model._serialize = False
self.generic_model.prepare(
inference_conda_env="dataexpl_p37_cpu_v3",
Expand Down
14 changes: 13 additions & 1 deletion tests/unitary/with_extras/model/test_model_deployment_details.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@

import os
from unittest import TestCase
from unittest.mock import patch

import yaml
from ads.model.runtime.model_deployment_details import ModelDeploymentDetails
Expand All @@ -27,7 +28,18 @@ def setUpClass(cls):
with open(os.path.join(curr_dir, "runtime_fail.yaml"), encoding="utf-8") as rt:
cls.runtime_dict_fail = yaml.load(rt, loader)

def test_from_dict(self):
@patch("ads.model.runtime.env_info.get_service_packs")
def test_from_dict(self, mock_get_service_packs):
inference_conda_env="oci://service-conda-packs@ociodscdev/service_pack/cpu/General_Machine_Learning_for_CPUs/1.0/mlcpuv1"
inference_python_version="3.6"
mock_get_service_packs.return_value = (
{
inference_conda_env : ("mlcpuv1", inference_python_version),
},
{
"mlcpuv1" : (inference_conda_env, inference_python_version),
}
)
model_deployment = ModelDeploymentDetails.from_dict(
self.runtime_dict["MODEL_DEPLOYMENT"]
)
Expand Down
29 changes: 27 additions & 2 deletions tests/unitary/with_extras/model/test_model_metadata_mixin.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
# Copyright (c) 2022, 2023 Oracle and/or its affiliates.
# Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl/

from unittest.mock import patch
import numpy as np
import pytest
from sklearn import datasets, linear_model
Expand Down Expand Up @@ -104,7 +105,19 @@ def test_metadata_generic_model_container_runtime(self):
)
assert model.metadata_provenance.training_id is None

def test_metadata_sklearn_model(self):
@patch("ads.model.runtime.env_info.get_service_packs")
def test_metadata_sklearn_model(self, mock_get_service_packs):
conda_env="oci://service-conda-packs@ociodscdev/service_pack/cpu/Data_Exploration_and_Manipulation_for_CPU_Python_3.7/3.0/dataexpl_p37_cpu_v3"
python_version="3.7"
mock_get_service_packs.return_value = (
{
conda_env : ("dataexpl_p37_cpu_v3", python_version),
},
{
"dataexpl_p37_cpu_v3" : (conda_env, python_version),

}
)
model = SklearnModel(self.rgr, artifact_dir="./test_sklearn")
model.prepare(
inference_conda_env="dataexpl_p37_cpu_v3",
Expand Down Expand Up @@ -146,7 +159,19 @@ def test_metadata_sklearn_model(self):
)
assert model.metadata_provenance.training_id is None

def test_metadata_xgboost_model(self):
@patch("ads.model.runtime.env_info.get_service_packs")
def test_metadata_xgboost_model(self, mock_get_service_packs):
conda_env="oci://service-conda-packs@ociodscdev/service_pack/cpu/Data_Exploration_and_Manipulation_for_CPU_Python_3.7/3.0/dataexpl_p37_cpu_v3"
python_version="3.7"
mock_get_service_packs.return_value = (
{
conda_env : ("dataexpl_p37_cpu_v3", python_version),
},
{
"dataexpl_p37_cpu_v3" : (conda_env, python_version),

}
)
model = XGBoostModel(self.xgb_rgr, artifact_dir="./test_xgboost")
model.prepare(
inference_conda_env="dataexpl_p37_cpu_v3",
Expand Down
16 changes: 14 additions & 2 deletions tests/unitary/with_extras/model/test_model_provenance_details.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
# Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl/

import os
from unittest.mock import patch

import yaml
from ads.model.runtime.model_provenance_details import (
Expand Down Expand Up @@ -57,8 +58,19 @@ def setup_class(cls):
with open(os.path.join(curr_dir, "runtime_fail.yaml"), encoding="utf-8") as rt:
cls.runtime_dict_fail = yaml.load(rt, loader)

def test_from_dict(self):

@patch("ads.model.runtime.env_info.get_service_packs")
def test_from_dict(self, mock_get_service_packs):
conda_env="oci://service_conda_packs@ociodscdev/service_pack/cpu/General_Machine_Learning_for_CPUs/1.0/mlcpuv1"
python_version="3.6"
mock_get_service_packs.return_value = (
{
conda_env : ("mlcpuv1", python_version),
},
{
"mlcpuv1" : (conda_env, python_version),

}
)
model_provenance = ModelProvenanceDetails.from_dict(
self.runtime_dict["MODEL_PROVENANCE"]
)
Expand Down
42 changes: 39 additions & 3 deletions tests/unitary/with_extras/model/test_runtime_info.py
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,19 @@ def test__validate_dict_fail(self):
with pytest.raises(AssertionError):
RuntimeInfo._validate_dict(self.runtime_dict_fail)

def test_from_yaml(self):
@patch("ads.model.runtime.env_info.get_service_packs")
def test_from_yaml(self, mock_get_service_packs):
conda_env="oci://service_conda_packs@ociodscdev/service_pack/cpu/General_Machine_Learning_for_CPUs/1.0/mlcpuv1"
python_version="3.6"
mock_get_service_packs.return_value = (
{
conda_env : ("mlcpuv1", python_version),
},
{
"mlcpuv1" : (conda_env, python_version),

}
)
runtime_info = RuntimeInfo.from_yaml(
uri=os.path.join(self.curr_dir, "runtime.yaml")
)
Expand Down Expand Up @@ -95,7 +107,19 @@ def test_from_yaml(self):

@patch.object(InferenceEnvInfo, "_validate", side_effect=DocumentError)
@patch.object(TrainingEnvInfo, "_validate", side_effect=DocumentError)
def test_from_yaml_fail(self, mock_inference, mock_training):
@patch("ads.model.runtime.env_info.get_service_packs")
def test_from_yaml_fail(self, mock_get_service_packs, mock_inference, mock_training):
conda_env="oci://service_conda_packs@ociodscdev/service_pack/cpu/General_Machine_Learning_for_CPUs/1.0/mlcpuv1"
python_version="3.6"
mock_get_service_packs.return_value = (
{
conda_env : ("mlcpuv1", python_version),
},
{
"mlcpuv1" : (conda_env, python_version),

}
)
with pytest.raises(DocumentError):
RuntimeInfo.from_yaml(uri=os.path.join(self.curr_dir, "runtime_fail.yaml"))

Expand All @@ -119,7 +143,19 @@ def test_from_yaml_wrong_format(self, mock_provenance, mock_deployment):
with pytest.raises(FileNotFoundError):
RuntimeInfo.from_yaml(uri=os.path.join(self.curr_dir, "fake.yaml"))

def test_from_and_to_yaml_file(self):
@patch("ads.model.runtime.env_info.get_service_packs")
def test_from_and_to_yaml_file(self, mock_get_service_packs):
conda_env="oci://service_conda_packs@ociodscdev/service_pack/cpu/General_Machine_Learning_for_CPUs/1.0/mlcpuv1"
python_version="3.6"
mock_get_service_packs.return_value = (
{
conda_env : ("mlcpuv1", python_version),
},
{
"mlcpuv1" : (conda_env, python_version),

}
)
runtime = RuntimeInfo.from_yaml(uri=os.path.join(self.curr_dir, "runtime.yaml"))
runtime.to_yaml(uri=os.path.join(self.curr_dir, "runtime_copy.yaml"))
runtime_copy = RuntimeInfo.from_yaml(
Expand Down

0 comments on commit 95fe7fa

Please sign in to comment.