diff --git a/README.md b/README.md
index 8447474f..a5fd1262 100644
--- a/README.md
+++ b/README.md
@@ -164,8 +164,6 @@ For example:
 
 ## Pre/Post-Processing
 
-**NOTE: There is currently no support for pre-/post-processing with multi-model containers.**
-
 SageMaker TensorFlow Serving Container supports the following Content-Types for requests:
 
 * `application/json` (default)
@@ -181,7 +179,8 @@ The container will convert data in these formats to [TensorFlow Serving REST API
 and will send these requests to the default serving signature of your SavedModel bundle.
 
 You can also add customized Python code to process your input and output data. To use this feature, you need to:
-1. Add a python file named `inference.py` to the code directory inside your model archive.
+1. Add a python file named `inference.py` to the `code` directory inside your model archive.
+2. If you want to use a universal `inference.py` file with a multi-model endpoint, then include it in the `code` directory at the s3 URI where the model archives are stored.
 2. In `inference.py`, implement either a pair of `input_handler` and `output_handler` functions or a single `handler` function. Note that if `handler` function is implemented, `input_handler` and `output_handler` will be ignored.
 
 To implement pre/post-processing handler(s), you will need to make use of the `Context` object created by Python service. The `Context` is a `namedtuple` with following attributes:
@@ -359,12 +358,14 @@ def _process_output(data, context):
 
 You can also bring in external dependencies to help with your data processing. There are 2 ways to do this:
 1. If your model archive contains `code/requirements.txt`, the container will install the Python dependencies at runtime using `pip install -r`.
+2. If you invoke a multi-model endpoint, only the universal `requirements.txt` file's Python dependencies will be installed at runtime. Dependencies specified in any `requirements.txt` file present in a model archive will not be installed.
 2. If you are working in a network-isolation situation or if you don't want to install dependencies at runtime everytime your Endpoint starts or Batch Transform job runs, you may want to put pre-downloaded dependencies under `code/lib` directory in your model archive, the container will then add the modules to the Python path. Note that if both `code/lib` and `code/requirements.txt` are present in the model archive, the `requirements.txt` will be ignored.
 
 Your untarred model directory structure may look like this if you are using `requirements.txt`:
 
         model1
             |--[model_version_number]
+                |--assets
                 |--variables
                 |--saved_model.pb
         model2
@@ -380,6 +381,7 @@ Your untarred model directory structure may look like this if you have downloade
 
         model1
             |--[model_version_number]
+                |--assets
                 |--variables
                 |--saved_model.pb
         model2
@@ -672,13 +674,14 @@ Only 90% of the ports will be utilized and each loaded model will be allocated w
 For example, if the ``SAGEMAKER_SAFE_PORT_RANGE`` is between 9000 to 9999, the maximum number of models that can be loaded to the endpoint at the same time would be 499 ((9999 - 9000) * 0.9 / 2).
 
 ### Using Multi-Model Endpoint with Pre/Post-Processing
-Multi-Model Endpoint can be used together with Pre/Post-Processing. Each model will need its own ``inference.py`` otherwise default handlers will be used. An example of the directory structure of Multi-Model Endpoint and Pre/Post-Processing would look like this:
+Multi-Model Endpoint can be used together with Pre/Post-Processing. Each model can either have its own ``inference.py`` or use a universal ``inference.py``. If both model-specific and universal ``inference.py`` files are provided, then the model-specific ``inference.py`` file is used. If both files are absent, then the default handlers will be used. An example of the directory structure of Multi-Model Endpoint with a model-specific ``inference.py`` file would look like this:
 
-        /opt/ml/models/model1/model
+        model1
             |--[model_version_number]
+                |--assets
                 |--variables
                 |--saved_model.pb
-        /opt/ml/models/model2/model
+        model2
             |--[model_version_number]
                 |--assets
                 |--variables
@@ -687,7 +690,21 @@ Multi-Model Endpoint can be used together with Pre/Post-Processing. Each model w
                 |--lib
                     |--external_module
                 |--inference.py
+Another example with of the directory structure of Multi-Model Endpoint with a universal ``inference.py`` file is as follows:
 
+        model1
+            |--[model_version_number]
+                |--assets
+                |--variables
+                |--saved_model.pb
+        model2
+            |--[model_version_number]
+                |--assets
+                |--variables
+                |--saved_model.pb
+        code
+            |--requirements.txt
+            |--inference.py
 ## Contributing
 
 Please read [CONTRIBUTING.md](https://github.com/aws/sagemaker-tensorflow-serving-container/blob/master/CONTRIBUTING.md)
diff --git a/docker/build_artifacts/sagemaker/python_service.py b/docker/build_artifacts/sagemaker/python_service.py
index fd9954cc..23bdea9a 100644
--- a/docker/build_artifacts/sagemaker/python_service.py
+++ b/docker/build_artifacts/sagemaker/python_service.py
@@ -17,6 +17,7 @@
 import os
 import subprocess
 import grpc
+import sys
 
 import falcon
 import requests
@@ -26,8 +27,8 @@
 import tfs_utils
 
 SAGEMAKER_MULTI_MODEL_ENABLED = os.environ.get("SAGEMAKER_MULTI_MODEL", "false").lower() == "true"
-MODEL_DIR = "models" if SAGEMAKER_MULTI_MODEL_ENABLED else "model"
-INFERENCE_SCRIPT_PATH = f"/opt/ml/{MODEL_DIR}/code/inference.py"
+MODEL_DIR = "" if SAGEMAKER_MULTI_MODEL_ENABLED else "model/"
+INFERENCE_SCRIPT_PATH = f"/opt/ml/{MODEL_DIR}code/inference.py"
 
 SAGEMAKER_BATCHING_ENABLED = os.environ.get("SAGEMAKER_TFS_ENABLE_BATCHING", "false").lower()
 MODEL_CONFIG_FILE_PATH = "/sagemaker/model-config.cfg"
@@ -77,6 +78,7 @@ def __init__(self):
                 # between each grpc port and channel
                 self._setup_channel(grpc_port)
 
+        self._default_handlers_enabled = False
         if os.path.exists(INFERENCE_SCRIPT_PATH):
             # Single-Model Mode & Multi-Model Mode both use one inference.py
             self._handler, self._input_handler, self._output_handler = self._import_handlers()
@@ -85,6 +87,7 @@ def __init__(self):
             )
         else:
             self._handlers = default_handler
+            self._default_handlers_enabled = True
 
         self._tfs_enable_batching = SAGEMAKER_BATCHING_ENABLED == "true"
         self._tfs_default_model_name = os.environ.get("TFS_DEFAULT_MODEL_NAME", "None")
@@ -143,6 +146,7 @@ def _handle_load_model_post(self, res, data):  # noqa: C901
         # validate model files are in the specified base_path
         if self.validate_model_dir(base_path):
             try:
+                self._import_custom_modules(model_name)
                 tfs_config = tfs_utils.create_tfs_config_individual_model(model_name, base_path)
                 tfs_config_file = "/sagemaker/tfs-config/{}/model-config.cfg".format(model_name)
                 log.info("tensorflow serving model config: \n%s\n", tfs_config)
@@ -221,6 +225,17 @@ def _handle_load_model_post(self, res, data):  # noqa: C901
                 }
             )
 
+    def _import_custom_modules(self, model_name):
+        inference_script_path = "/opt/ml/models/{}/model/code/inference.py".format(model_name)
+        python_lib_path = "/opt/ml/models/{}/model/code/lib".format(model_name)
+        if os.path.exists(python_lib_path):
+            log.info("add Python code library path")
+            sys.path.append(python_lib_path)
+        if os.path.exists(inference_script_path):
+            handler, input_handler, output_handler = self._import_handlers(inference_script_path)
+            model_handlers = self._make_handler(handler, input_handler, output_handler)
+            self.model_handlers[model_name] = model_handlers
+
     def _cleanup_config_file(self, config_file):
         if os.path.exists(config_file):
             os.remove(config_file)
@@ -264,8 +279,20 @@ def _handle_invocation_post(self, req, res, model_name=None):
 
         try:
             res.status = falcon.HTTP_200
-
-            res.body, res.content_type = self._handlers(data, context)
+            handlers = self._handlers
+            if SAGEMAKER_MULTI_MODEL_ENABLED and model_name in self.model_handlers:
+                inference_script_path = "/opt/ml/models/{}/model/code/" \
+                                        "inference.py".format(model_name)
+                log.info("Inference script found at path {}.".format(inference_script_path))
+                log.info("Inference script exists, importing handlers.")
+                handlers = self.model_handlers[model_name]
+            elif not self._default_handlers_enabled:
+                log.info("Universal inference script found at path "
+                         "{}.".format(INFERENCE_SCRIPT_PATH))
+                log.info("Universal inference script exists, importing handlers.")
+            else:
+                log.info("Inference script does not exist, using default handlers.")
+            res.body, res.content_type = handlers(data, context)
         except Exception as e:  # pylint: disable=broad-except
             log.exception("exception handling request: {}".format(e))
             res.status = falcon.HTTP_500
@@ -276,8 +303,7 @@ def _setup_channel(self, grpc_port):
             log.info("Creating grpc channel for port: %s", grpc_port)
             self._channels[grpc_port] = grpc.insecure_channel("localhost:{}".format(grpc_port))
 
-    def _import_handlers(self):
-        inference_script = INFERENCE_SCRIPT_PATH
+    def _import_handlers(self, inference_script=INFERENCE_SCRIPT_PATH):
         spec = importlib.util.spec_from_file_location("inference", inference_script)
         inference = importlib.util.module_from_spec(spec)
         spec.loader.exec_module(inference)
diff --git a/docker/build_artifacts/sagemaker/serve.py b/docker/build_artifacts/sagemaker/serve.py
index 2d0c7cca..82a225a9 100644
--- a/docker/build_artifacts/sagemaker/serve.py
+++ b/docker/build_artifacts/sagemaker/serve.py
@@ -28,9 +28,8 @@
 JS_INVOCATIONS = "js_content tensorflowServing.invocations"
 GUNICORN_PING = "proxy_pass http://gunicorn_upstream/ping"
 GUNICORN_INVOCATIONS = "proxy_pass http://gunicorn_upstream/invocations"
-MULTI_MODEL = "s" if os.environ.get("SAGEMAKER_MULTI_MODEL", "False").lower() == "true" else ""
-MODEL_DIR = f"model{MULTI_MODEL}"
-CODE_DIR = "/opt/ml/{}/code".format(MODEL_DIR)
+MODEL_DIR = "" if os.environ.get("SAGEMAKER_MULTI_MODEL", "False").lower() == "true" else "model/"
+CODE_DIR = f"/opt/ml/{MODEL_DIR}code"
 PYTHON_LIB_PATH = os.path.join(CODE_DIR, "lib")
 REQUIREMENTS_PATH = os.path.join(CODE_DIR, "requirements.txt")
 INFERENCE_PATH = os.path.join(CODE_DIR, "inference.py")
@@ -134,7 +133,8 @@ def __init__(self):
         os.environ["TFS_REST_PORTS"] = self._tfs_rest_concat_ports
 
     def _need_python_service(self):
-        if os.path.exists(INFERENCE_PATH):
+        if (os.path.exists(INFERENCE_PATH) or os.path.exists(REQUIREMENTS_PATH)
+                or os.path.exists(PYTHON_LIB_PATH)):
             self._enable_python_service = True
         if os.environ.get("SAGEMAKER_MULTI_MODEL_UNIVERSAL_BUCKET") and os.environ.get(
             "SAGEMAKER_MULTI_MODEL_UNIVERSAL_PREFIX"
@@ -256,7 +256,7 @@ def _download_scripts(self, bucket, prefix):
         paginator = client.get_paginator("list_objects")
         for result in paginator.paginate(Bucket=bucket, Delimiter="/", Prefix=prefix):
             for file in result.get("Contents", []):
-                destination = os.path.join(CODE_DIR, file.get("Key"))
+                destination = os.path.join(CODE_DIR, file.get("Key").split("/")[-1])
                 if not os.path.exists(os.path.dirname(destination)):
                     os.makedirs(os.path.dirname(destination))
                 resource.meta.client.download_file(bucket, file.get("Key"), destination)
diff --git a/docker/build_artifacts/sagemaker/tensorflowServing.js b/docker/build_artifacts/sagemaker/tensorflowServing.js
index 96a00695..f61a28c2 100644
--- a/docker/build_artifacts/sagemaker/tensorflowServing.js
+++ b/docker/build_artifacts/sagemaker/tensorflowServing.js
@@ -68,7 +68,6 @@ function tfs_json_request(r, json) {
         method: 'POST',
         body: json
     }
-
     var accept = r.headersIn.Accept
     function callback (reply) {
         var body = reply.responseBody
@@ -76,7 +75,6 @@ function tfs_json_request(r, json) {
             // "fix" broken json escaping in \'instances\' message
             body = body.replace("\\'instances\\'", "'instances'")
         }
-
         if (accept != undefined) {
             var content_types = accept.trim().replace(" ", "").split(",")
             if (content_types.includes('application/jsonlines') || content_types.includes('application/json')) {
diff --git a/test/integration/local/test_pre_post_processing_mme.py b/test/integration/local/test_pre_post_processing_mme1.py
similarity index 55%
rename from test/integration/local/test_pre_post_processing_mme.py
rename to test/integration/local/test_pre_post_processing_mme1.py
index 5eb0fb6e..6197af90 100644
--- a/test/integration/local/test_pre_post_processing_mme.py
+++ b/test/integration/local/test_pre_post_processing_mme1.py
@@ -11,9 +11,11 @@
 # ANY KIND, either express or implied. See the License for the specific
 # language governing permissions and limitations under the License.
 
+# In this test, only a universal inference.py file is provided. It's expected the handlers from the universal
+# inference.py file should be used by both models.
+
 import json
 import os
-import shutil
 import subprocess
 import sys
 import time
@@ -27,19 +29,19 @@
 
 PING_URL = "http://localhost:8080/ping"
 INVOCATION_URL = "http://localhost:8080/models/{}/invoke"
-MODEL_NAME = "half_plus_three"
+MODEL_NAMES = ["half_plus_three","half_plus_two"]
 
 
 @pytest.fixture(scope="session", autouse=True)
 def volume():
     try:
-        model_dir = os.path.abspath("test/resources/mme_universal_script")
+        model_dir = os.path.abspath("test/resources/mme1")
         subprocess.check_call(
-            "docker volume create --name model_volume_mme --opt type=none "
+            "docker volume create --name model_volume_mme1 --opt type=none "
             "--opt device={} --opt o=bind".format(model_dir).split())
         yield model_dir
     finally:
-        subprocess.check_call("docker volume rm model_volume_mme".split())
+        subprocess.check_call("docker volume rm model_volume_mme1".split())
 
 
 @pytest.fixture(scope="module", autouse=True)
@@ -47,7 +49,7 @@ def container(docker_base_name, tag, runtime_config):
     try:
         command = (
             "docker run {}--name sagemaker-tensorflow-serving-test -p 8080:8080"
-            " --mount type=volume,source=model_volume_mme,target=/opt/ml/models,readonly"
+            " --mount type=volume,source=model_volume_mme1,target=/opt/ml,readonly"
             " -e SAGEMAKER_TFS_NGINX_LOGLEVEL=info"
             " -e SAGEMAKER_BIND_TO_PORT=8080"
             " -e SAGEMAKER_SAFE_PORT_RANGE=9000-9999"
@@ -74,13 +76,14 @@ def container(docker_base_name, tag, runtime_config):
 
 
 @pytest.fixture
-def model():
-    model_data = {
-        "model_name": MODEL_NAME,
-        "url": "/opt/ml/models/half_plus_three/model/half_plus_three"
-    }
-    make_load_model_request(json.dumps(model_data))
-    return MODEL_NAME
+def models():
+    for MODEL_NAME in MODEL_NAMES:
+        model_data = {
+            "model_name": MODEL_NAME,
+            "url": "/opt/ml/models/{}/model".format(MODEL_NAME)
+        }
+        make_load_model_request(json.dumps(model_data))
+    return MODEL_NAMES
 
 
 @pytest.mark.skip_gpu
@@ -90,20 +93,25 @@ def test_ping_service():
 
 
 @pytest.mark.skip_gpu
-def test_predict_json(model):
+def test_predict_json(models):
     headers = make_headers()
     data = "{\"instances\": [1.0, 2.0, 5.0]}"
-    response = requests.post(INVOCATION_URL.format(model), data=data, headers=headers).json()
-    assert response == {"predictions": [3.5, 4.0, 5.5]}
+    responses = []
+    for model in models:
+        response = requests.post(INVOCATION_URL.format(model), data=data, headers=headers).json()
+        responses.append(response)
+    assert responses[0] == {"predictions": [3.5, 4.0, 5.5]}
+    assert responses[1] == {"predictions": [2.5, 3.0, 4.5]}
 
 
 @pytest.mark.skip_gpu
 def test_zero_content():
     headers = make_headers()
     x = ""
-    response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=x, headers=headers)
-    assert 500 == response.status_code
-    assert "document is empty" in response.text
+    for MODEL_NAME in MODEL_NAMES:
+        response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=x, headers=headers)
+        assert 500 == response.status_code
+        assert "document is empty" in response.text
 
 
 @pytest.mark.skip_gpu
@@ -113,34 +121,43 @@ def test_large_input():
     with open(data_file, "r") as file:
         x = file.read()
         headers = make_headers(content_type="text/csv")
-        response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=x, headers=headers).json()
-        predictions = response["predictions"]
-        assert len(predictions) == 753936
+        for MODEL_NAME in MODEL_NAMES:
+            response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=x, headers=headers).json()
+            predictions = response["predictions"]
+            assert len(predictions) == 753936
 
 
 @pytest.mark.skip_gpu
 def test_csv_input():
     headers = make_headers(content_type="text/csv")
     data = "1.0,2.0,5.0"
-    response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers).json()
-    assert response == {"predictions": [3.5, 4.0, 5.5]}
-
+    responses = []
+    for MODEL_NAME in MODEL_NAMES:
+        response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers).json()
+        responses.append(response)
+    assert responses[0] == {"predictions": [3.5, 4.0, 5.5]}
+    assert responses[1] == {"predictions": [2.5, 3.0, 4.5]}
 
 @pytest.mark.skip_gpu
 def test_specific_versions():
-    for version in ("123", "124"):
-        headers = make_headers(content_type="text/csv", version=version)
-        data = "1.0,2.0,5.0"
-        response = requests.post(
-            INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers
-        ).json()
-        assert response == {"predictions": [3.5, 4.0, 5.5]}
+    for MODEL_NAME in MODEL_NAMES:
+        for version in ("123", "124"):
+            headers = make_headers(content_type="text/csv", version=version)
+            data = "1.0,2.0,5.0"
+            response = requests.post(
+                INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers
+            ).json()
+            if MODEL_NAME == "half_plus_three":
+                assert response == {"predictions": [3.5, 4.0, 5.5]}
+            else:
+                assert response == {"predictions": [2.5, 3.0, 4.5]}
 
 
 @pytest.mark.skip_gpu
 def test_unsupported_content_type():
     headers = make_headers("unsupported-type", "predict")
     data = "aW1hZ2UgYnl0ZXM="
-    response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers)
-    assert 500 == response.status_code
-    assert "unsupported content type" in response.text
+    for MODEL_NAME in MODEL_NAMES:
+        response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers)
+        assert 500 == response.status_code
+        assert "unsupported content type" in response.text
diff --git a/test/integration/local/test_pre_post_processing_mme2.py b/test/integration/local/test_pre_post_processing_mme2.py
new file mode 100644
index 00000000..901902f7
--- /dev/null
+++ b/test/integration/local/test_pre_post_processing_mme2.py
@@ -0,0 +1,175 @@
+# Copyright 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"). You
+# may not use this file except in compliance with the License. A copy of
+# the License is located at
+#
+#     http://aws.amazon.com/apache2.0/
+#
+# or in the "license" file accompanying this file. This file is
+# distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
+# ANY KIND, either express or implied. See the License for the specific
+# language governing permissions and limitations under the License.
+
+# The model-specific inference.py files for both models and the universal inference.py file are provided. It is
+# expected that the handlers from the model-specific inference.py files should be used and the handlers from the
+# universal inference.py file should be ignored.
+
+import json
+import os
+import subprocess
+import sys
+import time
+
+import pytest
+
+import requests
+
+from multi_model_endpoint_test_utils import make_load_model_request, make_headers
+
+
+PING_URL = "http://localhost:8080/ping"
+INVOCATION_URL = "http://localhost:8080/models/{}/invoke"
+MODEL_NAMES = ["half_plus_three","half_plus_two"]
+
+
+@pytest.fixture(scope="session", autouse=True)
+def volume():
+    try:
+        model_dir = os.path.abspath("test/resources/mme2")
+        subprocess.check_call(
+            "docker volume create --name model_volume_mme2 --opt type=none "
+            "--opt device={} --opt o=bind".format(model_dir).split())
+        yield model_dir
+    finally:
+        subprocess.check_call("docker volume rm model_volume_mme2".split())
+
+
+@pytest.fixture(scope="module", autouse=True)
+def container(docker_base_name, tag, runtime_config):
+    try:
+        command = (
+            "docker run {}--name sagemaker-tensorflow-serving-test -p 8080:8080"
+            " --mount type=volume,source=model_volume_mme2,target=/opt/ml,readonly"
+            " -e SAGEMAKER_TFS_NGINX_LOGLEVEL=info"
+            " -e SAGEMAKER_BIND_TO_PORT=8080"
+            " -e SAGEMAKER_SAFE_PORT_RANGE=9000-9999"
+            " -e SAGEMAKER_MULTI_MODEL=True"
+            " {}:{} serve"
+        ).format(runtime_config, docker_base_name, tag)
+
+        proc = subprocess.Popen(command.split(), stdout=sys.stdout, stderr=subprocess.STDOUT)
+
+        attempts = 0
+        while attempts < 40:
+            time.sleep(3)
+            try:
+                res_code = requests.get("http://localhost:8080/ping").status_code
+                if res_code == 200:
+                    break
+            except:
+                attempts += 1
+                pass
+
+        yield proc.pid
+    finally:
+        subprocess.check_call("docker rm -f sagemaker-tensorflow-serving-test".split())
+
+
+@pytest.fixture
+def models():
+    for MODEL_NAME in MODEL_NAMES:
+        model_data = {
+            "model_name": MODEL_NAME,
+            "url": "/opt/ml/models/{}/model".format(MODEL_NAME)
+        }
+        make_load_model_request(json.dumps(model_data))
+    return MODEL_NAMES
+
+
+@pytest.mark.skip_gpu
+def test_ping_service():
+    response = requests.get(PING_URL)
+    assert 200 == response.status_code
+
+
+@pytest.mark.skip_gpu
+def test_predict_json(models):
+    headers = make_headers()
+    data = "{\"instances\": [1.0, 2.0, 5.0]}"
+    responses = []
+    for model in models:
+        response = requests.post(INVOCATION_URL.format(model), data=data, headers=headers).json()
+        responses.append(response)
+    assert responses[0] == {"predictions": [3.5, 4.0, 5.5]}
+    error = responses[1]["error"]
+    assert "unsupported content type application/json" in error
+
+
+@pytest.mark.skip_gpu
+def test_zero_content():
+    headers = make_headers()
+    x = ""
+    responses = []
+    for MODEL_NAME in MODEL_NAMES:
+        response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=x, headers=headers)
+        responses.append(response)
+        print(MODEL_NAME,response)
+    assert 500 == responses[0].status_code
+    assert "document is empty" in responses[0].text
+    assert 500 == responses[1].status_code
+    assert "unsupported content type application/json" in responses[1].text
+
+
+@pytest.mark.skip_gpu
+def test_large_input():
+    data_file = "test/resources/inputs/test-large.csv"
+
+    with open(data_file, "r") as file:
+        x = file.read()
+        headers = make_headers(content_type="text/csv")
+        responses = []
+        for MODEL_NAME in MODEL_NAMES:
+            response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=x, headers=headers).json()
+            responses.append(response)
+        error = responses[0]["error"]
+        assert "unsupported content type text/csv" in error
+        predictions = responses[1]["predictions"]
+        assert len(predictions) == 753936
+
+
+@pytest.mark.skip_gpu
+def test_csv_input():
+    headers = make_headers(content_type="text/csv")
+    data = "1.0,2.0,5.0"
+    responses = []
+    for MODEL_NAME in MODEL_NAMES:
+        response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers).json()
+        responses.append(response)
+    error = responses[0]["error"]
+    assert "unsupported content type text/csv" in error
+    assert responses[1] == {"predictions": [2.5, 3.0, 4.5]}
+
+@pytest.mark.skip_gpu
+def test_specific_versions():
+    for MODEL_NAME in MODEL_NAMES:
+        for version in ("123", "124"):
+            headers = make_headers(content_type="text/csv", version=version)
+            data = "1.0,2.0,5.0"
+            response = requests.post(
+                INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers
+            ).json()
+            if MODEL_NAME == "half_plus_three":
+                error = response["error"]
+                assert "unsupported content type text/csv" in error
+            else:
+                assert response == {"predictions": [2.5, 3.0, 4.5]}
+
+@pytest.mark.skip_gpu
+def test_unsupported_content_type():
+    headers = make_headers("unsupported-type", "predict")
+    data = "aW1hZ2UgYnl0ZXM="
+    for MODEL_NAME in MODEL_NAMES:
+        response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers)
+        assert 500 == response.status_code
+        assert "unsupported content type" in response.text
diff --git a/test/integration/local/test_pre_post_processing_mme3.py b/test/integration/local/test_pre_post_processing_mme3.py
new file mode 100644
index 00000000..7356da8e
--- /dev/null
+++ b/test/integration/local/test_pre_post_processing_mme3.py
@@ -0,0 +1,176 @@
+# Copyright 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"). You
+# may not use this file except in compliance with the License. A copy of
+# the License is located at
+#
+#     http://aws.amazon.com/apache2.0/
+#
+# or in the "license" file accompanying this file. This file is
+# distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
+# ANY KIND, either express or implied. See the License for the specific
+# language governing permissions and limitations under the License.
+
+# A model-specific inference.py file for the model half_plus_three and a universal inference.py file are provided. A
+# specific inference.py file for the model half_plus_two is not provided. It is expected that the handlers from the
+# model-specific inference.py file should be used for the model half_plus_three and the handlers from the universal
+# inference.py file should be used for the model half_plus_two.
+import json
+import os
+import subprocess
+import sys
+import time
+
+import pytest
+
+import requests
+
+from multi_model_endpoint_test_utils import make_load_model_request, make_headers
+
+
+PING_URL = "http://localhost:8080/ping"
+INVOCATION_URL = "http://localhost:8080/models/{}/invoke"
+MODEL_NAMES = ["half_plus_three","half_plus_two"]
+
+
+@pytest.fixture(scope="session", autouse=True)
+def volume():
+    try:
+        model_dir = os.path.abspath("test/resources/mme3")
+        subprocess.check_call(
+            "docker volume create --name model_volume_mme3 --opt type=none "
+            "--opt device={} --opt o=bind".format(model_dir).split())
+        yield model_dir
+    finally:
+        subprocess.check_call("docker volume rm model_volume_mme3".split())
+
+
+@pytest.fixture(scope="module", autouse=True)
+def container(docker_base_name, tag, runtime_config):
+    try:
+        command = (
+            "docker run {}--name sagemaker-tensorflow-serving-test -p 8080:8080"
+            " --mount type=volume,source=model_volume_mme3,target=/opt/ml,readonly"
+            " -e SAGEMAKER_TFS_NGINX_LOGLEVEL=info"
+            " -e SAGEMAKER_BIND_TO_PORT=8080"
+            " -e SAGEMAKER_SAFE_PORT_RANGE=9000-9999"
+            " -e SAGEMAKER_MULTI_MODEL=True"
+            " {}:{} serve"
+        ).format(runtime_config, docker_base_name, tag)
+
+        proc = subprocess.Popen(command.split(), stdout=sys.stdout, stderr=subprocess.STDOUT)
+
+        attempts = 0
+        while attempts < 40:
+            time.sleep(3)
+            try:
+                res_code = requests.get("http://localhost:8080/ping").status_code
+                if res_code == 200:
+                    break
+            except:
+                attempts += 1
+                pass
+
+        yield proc.pid
+    finally:
+        subprocess.check_call("docker rm -f sagemaker-tensorflow-serving-test".split())
+
+
+@pytest.fixture
+def models():
+    for MODEL_NAME in MODEL_NAMES:
+        model_data = {
+            "model_name": MODEL_NAME,
+            "url": "/opt/ml/models/{}/model".format(MODEL_NAME)
+        }
+        make_load_model_request(json.dumps(model_data))
+    return MODEL_NAMES
+
+
+@pytest.mark.skip_gpu
+def test_ping_service():
+    response = requests.get(PING_URL)
+    assert 200 == response.status_code
+
+
+@pytest.mark.skip_gpu
+def test_predict_json(models):
+    headers = make_headers()
+    data = "{\"instances\": [1.0, 2.0, 5.0]}"
+    responses = []
+    for model in models:
+        response = requests.post(INVOCATION_URL.format(model), data=data, headers=headers).json()
+        responses.append(response)
+    assert responses[0] == {"predictions": [3.5, 4.0, 5.5]}
+    error = responses[1]["error"]
+    assert "unsupported content type application/json" in error
+
+
+@pytest.mark.skip_gpu
+def test_zero_content():
+    headers = make_headers()
+    x = ""
+    responses = []
+    for MODEL_NAME in MODEL_NAMES:
+        response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=x, headers=headers)
+        responses.append(response)
+        print(MODEL_NAME,response)
+    assert 500 == responses[0].status_code
+    assert "document is empty" in responses[0].text
+    assert 500 == responses[1].status_code
+    assert "unsupported content type application/json" in responses[1].text
+
+
+@pytest.mark.skip_gpu
+def test_large_input():
+    data_file = "test/resources/inputs/test-large.csv"
+
+    with open(data_file, "r") as file:
+        x = file.read()
+        headers = make_headers(content_type="text/csv")
+        responses = []
+        for MODEL_NAME in MODEL_NAMES:
+            response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=x, headers=headers).json()
+            responses.append(response)
+        error = responses[0]["error"]
+        assert "unsupported content type text/csv" in error
+        predictions = responses[1]["predictions"]
+        assert len(predictions) == 753936
+
+
+@pytest.mark.skip_gpu
+def test_csv_input():
+    headers = make_headers(content_type="text/csv")
+    data = "1.0,2.0,5.0"
+    responses = []
+    for MODEL_NAME in MODEL_NAMES:
+        response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers).json()
+        responses.append(response)
+    error = responses[0]["error"]
+    assert "unsupported content type text/csv" in error
+    assert responses[1] == {"predictions": [2.5, 3.0, 4.5]}
+
+@pytest.mark.skip_gpu
+def test_specific_versions():
+    for MODEL_NAME in MODEL_NAMES:
+        for version in ("123", "124"):
+            headers = make_headers(content_type="text/csv", version=version)
+            data = "1.0,2.0,5.0"
+            response = requests.post(
+                INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers
+            ).json()
+            if MODEL_NAME == "half_plus_three":
+                error = response["error"]
+                assert "unsupported content type text/csv" in error
+            else:
+                assert response == {"predictions": [2.5, 3.0, 4.5]}
+
+
+@pytest.mark.skip_gpu
+def test_unsupported_content_type():
+    headers = make_headers("unsupported-type", "predict")
+    data = "aW1hZ2UgYnl0ZXM="
+    for MODEL_NAME in MODEL_NAMES:
+        response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers)
+        assert 500 == response.status_code
+        assert "unsupported content type" in response.text
diff --git a/test/integration/local/test_pre_post_processing_mme4.py b/test/integration/local/test_pre_post_processing_mme4.py
new file mode 100644
index 00000000..622f4618
--- /dev/null
+++ b/test/integration/local/test_pre_post_processing_mme4.py
@@ -0,0 +1,178 @@
+# Copyright 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"). You
+# may not use this file except in compliance with the License. A copy of
+# the License is located at
+#
+#     http://aws.amazon.com/apache2.0/
+#
+# or in the "license" file accompanying this file. This file is
+# distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
+# ANY KIND, either express or implied. See the License for the specific
+# language governing permissions and limitations under the License.
+
+# Only a model-specific inference.py file for the model half_plus_three is provided. Neither a specific inference.py
+# file for the model half_plus_two nor a universal inference.py file is provided. It is expected that the handlers
+# from the model-specific inference.py file should be used for the model half_plus_three and the default handlers
+# should be used for the model half_plus_two.
+import json
+import os
+import subprocess
+import sys
+import time
+
+import pytest
+
+import requests
+
+from multi_model_endpoint_test_utils import make_load_model_request, make_headers
+
+
+PING_URL = "http://localhost:8080/ping"
+INVOCATION_URL = "http://localhost:8080/models/{}/invoke"
+MODEL_NAMES = ["half_plus_three","half_plus_two"]
+
+
+@pytest.fixture(scope="session", autouse=True)
+def volume():
+    try:
+        model_dir = os.path.abspath("test/resources/mme4")
+        subprocess.check_call(
+            "docker volume create --name model_volume_mme4 --opt type=none "
+            "--opt device={} --opt o=bind".format(model_dir).split())
+        yield model_dir
+    finally:
+        subprocess.check_call("docker volume rm model_volume_mme4".split())
+
+
+@pytest.fixture(scope="module", autouse=True)
+def container(docker_base_name, tag, runtime_config):
+    try:
+        command = (
+            "docker run {}--name sagemaker-tensorflow-serving-test -p 8080:8080"
+            " --mount type=volume,source=model_volume_mme4,target=/opt/ml,readonly"
+            " -e SAGEMAKER_TFS_NGINX_LOGLEVEL=info"
+            " -e SAGEMAKER_BIND_TO_PORT=8080"
+            " -e SAGEMAKER_SAFE_PORT_RANGE=9000-9999"
+            " -e SAGEMAKER_MULTI_MODEL=True"
+            " {}:{} serve"
+        ).format(runtime_config, docker_base_name, tag)
+
+        proc = subprocess.Popen(command.split(), stdout=sys.stdout, stderr=subprocess.STDOUT)
+
+        attempts = 0
+        while attempts < 40:
+            time.sleep(3)
+            try:
+                res_code = requests.get("http://localhost:8080/ping").status_code
+                if res_code == 200:
+                    break
+            except:
+                attempts += 1
+                pass
+
+        yield proc.pid
+    finally:
+        subprocess.check_call("docker rm -f sagemaker-tensorflow-serving-test".split())
+
+
+@pytest.fixture
+def models():
+    for MODEL_NAME in MODEL_NAMES:
+        model_data = {
+            "model_name": MODEL_NAME,
+            "url": "/opt/ml/models/{}/model".format(MODEL_NAME)
+        }
+        make_load_model_request(json.dumps(model_data))
+    return MODEL_NAMES
+
+
+@pytest.mark.skip_gpu
+def test_ping_service():
+    response = requests.get(PING_URL)
+    assert 200 == response.status_code
+
+
+@pytest.mark.skip_gpu
+def test_predict_json(models):
+    headers = make_headers()
+    data = "{\"instances\": [1.0, 2.0, 5.0]}"
+    responses = []
+    for model in models:
+        response = requests.post(INVOCATION_URL.format(model), data=data, headers=headers).json()
+        responses.append(response)
+    assert responses[0] == {"predictions": [3.5, 4.0, 5.5]}
+    assert responses[1] == {"predictions": [2.5, 3.0, 4.5]}
+
+
+@pytest.mark.skip_gpu
+def test_zero_content():
+    headers = make_headers()
+    x = ""
+    responses = []
+    for MODEL_NAME in MODEL_NAMES:
+        response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=x, headers=headers)
+        responses.append(response)
+        print(MODEL_NAME,response)
+    assert 500 == responses[0].status_code
+    assert "document is empty" in responses[0].text
+    assert 200 == responses[1].status_code
+    assert "document is empty" in responses[1].text
+
+
+@pytest.mark.skip_gpu
+def test_large_input():
+    data_file = "test/resources/inputs/test-large.csv"
+
+    with open(data_file, "r") as file:
+        x = file.read()
+        headers = make_headers(content_type="text/csv")
+        responses = []
+        for MODEL_NAME in MODEL_NAMES:
+            response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=x, headers=headers).json()
+            responses.append(response)
+        predictions = responses[0]["predictions"]
+        assert len(predictions) == 753936
+        error = responses[1]["error"]
+        assert "document root must not be followed by other values" in error
+
+
+@pytest.mark.skip_gpu
+def test_csv_input():
+    headers = make_headers(content_type="text/csv")
+    data = "1.0,2.0,5.0"
+    responses = []
+    for MODEL_NAME in MODEL_NAMES:
+        response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers).json()
+        responses.append(response)
+    assert responses[0] == {"predictions": [3.5, 4.0, 5.5]}
+    error = responses[1]["error"]
+    assert "document root must not be followed by other values" in error
+
+@pytest.mark.skip_gpu
+def test_specific_versions():
+    for MODEL_NAME in MODEL_NAMES:
+        for version in ("123", "124"):
+            headers = make_headers(content_type="text/csv", version=version)
+            data = "1.0,2.0,5.0"
+            response = requests.post(
+                INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers
+            ).json()
+            if MODEL_NAME == 'half_plus_three':
+                assert response == {"predictions": [3.5, 4.0, 5.5]}
+            else:
+                error = response["error"]
+                assert "document root must not be followed by other values" in error
+
+@pytest.mark.skip_gpu
+def test_unsupported_content_type():
+    headers = make_headers("unsupported-type", "predict")
+    data = "aW1hZ2UgYnl0ZXM="
+    responses = []
+    for MODEL_NAME in MODEL_NAMES:
+        response = requests.post(INVOCATION_URL.format(MODEL_NAME), data=data, headers=headers)
+        responses.append(response)
+    assert 500 == responses[0].status_code
+    assert "unsupported content type" in responses[0].text
+    assert 200 == responses[1].status_code
+    assert "Invalid value" in responses[1].text
diff --git a/test/resources/mme_universal_script/code/inference.py b/test/resources/mme1/code/inference.py
similarity index 100%
rename from test/resources/mme_universal_script/code/inference.py
rename to test/resources/mme1/code/inference.py
diff --git a/test/resources/mme_universal_script/code/requirements.txt b/test/resources/mme1/code/requirements.txt
similarity index 100%
rename from test/resources/mme_universal_script/code/requirements.txt
rename to test/resources/mme1/code/requirements.txt
diff --git a/test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000123/assets/foo.txt b/test/resources/mme1/models/half_plus_three/model/00000123/assets/foo.txt
similarity index 100%
rename from test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000123/assets/foo.txt
rename to test/resources/mme1/models/half_plus_three/model/00000123/assets/foo.txt
diff --git a/test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000123/saved_model.pb b/test/resources/mme1/models/half_plus_three/model/00000123/saved_model.pb
similarity index 100%
rename from test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000123/saved_model.pb
rename to test/resources/mme1/models/half_plus_three/model/00000123/saved_model.pb
diff --git a/test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000123/variables/variables.data-00000-of-00001 b/test/resources/mme1/models/half_plus_three/model/00000123/variables/variables.data-00000-of-00001
similarity index 100%
rename from test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000123/variables/variables.data-00000-of-00001
rename to test/resources/mme1/models/half_plus_three/model/00000123/variables/variables.data-00000-of-00001
diff --git a/test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000123/variables/variables.index b/test/resources/mme1/models/half_plus_three/model/00000123/variables/variables.index
similarity index 100%
rename from test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000123/variables/variables.index
rename to test/resources/mme1/models/half_plus_three/model/00000123/variables/variables.index
diff --git a/test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000124/assets/foo.txt b/test/resources/mme1/models/half_plus_three/model/00000124/assets/foo.txt
similarity index 100%
rename from test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000124/assets/foo.txt
rename to test/resources/mme1/models/half_plus_three/model/00000124/assets/foo.txt
diff --git a/test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000124/saved_model.pb b/test/resources/mme1/models/half_plus_three/model/00000124/saved_model.pb
similarity index 100%
rename from test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000124/saved_model.pb
rename to test/resources/mme1/models/half_plus_three/model/00000124/saved_model.pb
diff --git a/test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000124/variables/variables.data-00000-of-00001 b/test/resources/mme1/models/half_plus_three/model/00000124/variables/variables.data-00000-of-00001
similarity index 100%
rename from test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000124/variables/variables.data-00000-of-00001
rename to test/resources/mme1/models/half_plus_three/model/00000124/variables/variables.data-00000-of-00001
diff --git a/test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000124/variables/variables.index b/test/resources/mme1/models/half_plus_three/model/00000124/variables/variables.index
similarity index 100%
rename from test/resources/mme_universal_script/half_plus_three/model/half_plus_three/00000124/variables/variables.index
rename to test/resources/mme1/models/half_plus_three/model/00000124/variables/variables.index
diff --git a/test/resources/mme1/models/half_plus_two/model/00000123/saved_model.pb b/test/resources/mme1/models/half_plus_two/model/00000123/saved_model.pb
new file mode 100644
index 00000000..c79ebe01
Binary files /dev/null and b/test/resources/mme1/models/half_plus_two/model/00000123/saved_model.pb differ
diff --git a/test/resources/mme1/models/half_plus_two/model/00000123/variables/variables.data-00000-of-00001 b/test/resources/mme1/models/half_plus_two/model/00000123/variables/variables.data-00000-of-00001
new file mode 100644
index 00000000..15b75d6e
Binary files /dev/null and b/test/resources/mme1/models/half_plus_two/model/00000123/variables/variables.data-00000-of-00001 differ
diff --git a/test/resources/mme1/models/half_plus_two/model/00000123/variables/variables.index b/test/resources/mme1/models/half_plus_two/model/00000123/variables/variables.index
new file mode 100644
index 00000000..7ec9fb4f
Binary files /dev/null and b/test/resources/mme1/models/half_plus_two/model/00000123/variables/variables.index differ
diff --git a/test/resources/mme1/models/half_plus_two/model/00000124/saved_model.pb b/test/resources/mme1/models/half_plus_two/model/00000124/saved_model.pb
new file mode 100644
index 00000000..c79ebe01
Binary files /dev/null and b/test/resources/mme1/models/half_plus_two/model/00000124/saved_model.pb differ
diff --git a/test/resources/mme1/models/half_plus_two/model/00000124/variables/variables.data-00000-of-00001 b/test/resources/mme1/models/half_plus_two/model/00000124/variables/variables.data-00000-of-00001
new file mode 100644
index 00000000..15b75d6e
Binary files /dev/null and b/test/resources/mme1/models/half_plus_two/model/00000124/variables/variables.data-00000-of-00001 differ
diff --git a/test/resources/mme1/models/half_plus_two/model/00000124/variables/variables.index b/test/resources/mme1/models/half_plus_two/model/00000124/variables/variables.index
new file mode 100644
index 00000000..7ec9fb4f
Binary files /dev/null and b/test/resources/mme1/models/half_plus_two/model/00000124/variables/variables.index differ
diff --git a/test/resources/mme2/code/inference.py b/test/resources/mme2/code/inference.py
new file mode 100644
index 00000000..1e5450e8
--- /dev/null
+++ b/test/resources/mme2/code/inference.py
@@ -0,0 +1,29 @@
+# Copyright 2018-2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"). You
+# may not use this file except in compliance with the License. A copy of
+# the License is located at
+#
+#     http://aws.amazon.com/apache2.0/
+#
+# or in the "license" file accompanying this file. This file is
+# distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
+# ANY KIND, either express or implied. See the License for the specific
+# language governing permissions and limitations under the License.
+
+import json
+
+
+def handler(data, context):
+    """A default inference request handler that directly send post request to TFS rest port with
+    un-processed data and return un-processed response
+
+    :param data: input data
+    :param context: context instance that contains tfs_rest_uri
+    :return: inference response from TFS model server
+    """
+    data = data.read().decode("utf-8")
+    if not isinstance(data, str):
+        data = json.loads(data)
+    response = requests.post(context.rest_uri, data=data)
+    return response.content, context.accept_header
diff --git a/test/resources/mme2/code/requirements.txt b/test/resources/mme2/code/requirements.txt
new file mode 100644
index 00000000..2f34b076
--- /dev/null
+++ b/test/resources/mme2/code/requirements.txt
@@ -0,0 +1 @@
+Pillow>=6.2.2
\ No newline at end of file
diff --git a/test/resources/mme2/models/half_plus_three/model/00000123/assets/foo.txt b/test/resources/mme2/models/half_plus_three/model/00000123/assets/foo.txt
new file mode 100644
index 00000000..f9ff0366
--- /dev/null
+++ b/test/resources/mme2/models/half_plus_three/model/00000123/assets/foo.txt
@@ -0,0 +1 @@
+asset-file-contents
\ No newline at end of file
diff --git a/test/resources/mme2/models/half_plus_three/model/00000123/saved_model.pb b/test/resources/mme2/models/half_plus_three/model/00000123/saved_model.pb
new file mode 100644
index 00000000..71ac8582
Binary files /dev/null and b/test/resources/mme2/models/half_plus_three/model/00000123/saved_model.pb differ
diff --git a/test/resources/mme2/models/half_plus_three/model/00000123/variables/variables.data-00000-of-00001 b/test/resources/mme2/models/half_plus_three/model/00000123/variables/variables.data-00000-of-00001
new file mode 100644
index 00000000..74cf8663
Binary files /dev/null and b/test/resources/mme2/models/half_plus_three/model/00000123/variables/variables.data-00000-of-00001 differ
diff --git a/test/resources/mme2/models/half_plus_three/model/00000123/variables/variables.index b/test/resources/mme2/models/half_plus_three/model/00000123/variables/variables.index
new file mode 100644
index 00000000..ac030a9d
Binary files /dev/null and b/test/resources/mme2/models/half_plus_three/model/00000123/variables/variables.index differ
diff --git a/test/resources/mme2/models/half_plus_three/model/00000124/assets/foo.txt b/test/resources/mme2/models/half_plus_three/model/00000124/assets/foo.txt
new file mode 100644
index 00000000..56c3e54a
--- /dev/null
+++ b/test/resources/mme2/models/half_plus_three/model/00000124/assets/foo.txt
@@ -0,0 +1 @@
+asset-file-contents
diff --git a/test/resources/mme2/models/half_plus_three/model/00000124/saved_model.pb b/test/resources/mme2/models/half_plus_three/model/00000124/saved_model.pb
new file mode 100644
index 00000000..71ac8582
Binary files /dev/null and b/test/resources/mme2/models/half_plus_three/model/00000124/saved_model.pb differ
diff --git a/test/resources/mme2/models/half_plus_three/model/00000124/variables/variables.data-00000-of-00001 b/test/resources/mme2/models/half_plus_three/model/00000124/variables/variables.data-00000-of-00001
new file mode 100644
index 00000000..74cf8663
Binary files /dev/null and b/test/resources/mme2/models/half_plus_three/model/00000124/variables/variables.data-00000-of-00001 differ
diff --git a/test/resources/mme2/models/half_plus_three/model/00000124/variables/variables.index b/test/resources/mme2/models/half_plus_three/model/00000124/variables/variables.index
new file mode 100644
index 00000000..ac030a9d
Binary files /dev/null and b/test/resources/mme2/models/half_plus_three/model/00000124/variables/variables.index differ
diff --git a/test/resources/mme2/models/half_plus_three/model/code/inference.py b/test/resources/mme2/models/half_plus_three/model/code/inference.py
new file mode 100644
index 00000000..1809ce93
--- /dev/null
+++ b/test/resources/mme2/models/half_plus_three/model/code/inference.py
@@ -0,0 +1,58 @@
+# Copyright 2018-2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"). You
+# may not use this file except in compliance with the License. A copy of
+# the License is located at
+#
+#     http://aws.amazon.com/apache2.0/
+#
+# or in the "license" file accompanying this file. This file is
+# distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
+# ANY KIND, either express or implied. See the License for the specific
+# language governing permissions and limitations under the License.
+
+import json
+from collections import namedtuple
+
+import PIL
+
+Context = namedtuple('Context',
+                     'model_name, model_version, method, rest_uri, grpc_uri, '
+                     'custom_attributes, request_content_type, accept_header')
+
+
+def input_handler(data, context):
+    """ Pre-process request input before it is sent to TensorFlow Serving REST API
+
+    Args:
+        data (obj): the request data, in format of dict or string
+        context (Context): an object containing request and configuration details
+
+    Returns:
+        (dict): a JSON-serializable dict that contains request body and headers
+    """
+    if context.request_content_type == 'application/json':
+        # pass through json (assumes it's correctly formed)
+        d = data.read().decode('utf-8')
+        return d if len(d) else ''
+
+    raise ValueError('{{"error": "unsupported content type {}"}}'.format(
+        context.request_content_type or "unknown"))
+
+
+def output_handler(data, context):
+    """Post-process TensorFlow Serving output before it is returned to the client.
+
+    Args:
+        data (obj): the TensorFlow serving response
+        context (Context): an object containing request and configuration details
+
+    Returns:
+        (bytes, string): data to return to client, response content type
+    """
+    if data.status_code != 200:
+        raise ValueError(data.content.decode('utf-8'))
+
+    response_content_type = context.accept_header
+    prediction = data.content
+    return prediction, response_content_type
diff --git a/test/resources/mme2/models/half_plus_two/model/00000123/saved_model.pb b/test/resources/mme2/models/half_plus_two/model/00000123/saved_model.pb
new file mode 100644
index 00000000..c79ebe01
Binary files /dev/null and b/test/resources/mme2/models/half_plus_two/model/00000123/saved_model.pb differ
diff --git a/test/resources/mme2/models/half_plus_two/model/00000123/variables/variables.data-00000-of-00001 b/test/resources/mme2/models/half_plus_two/model/00000123/variables/variables.data-00000-of-00001
new file mode 100644
index 00000000..15b75d6e
Binary files /dev/null and b/test/resources/mme2/models/half_plus_two/model/00000123/variables/variables.data-00000-of-00001 differ
diff --git a/test/resources/mme2/models/half_plus_two/model/00000123/variables/variables.index b/test/resources/mme2/models/half_plus_two/model/00000123/variables/variables.index
new file mode 100644
index 00000000..7ec9fb4f
Binary files /dev/null and b/test/resources/mme2/models/half_plus_two/model/00000123/variables/variables.index differ
diff --git a/test/resources/mme2/models/half_plus_two/model/00000124/saved_model.pb b/test/resources/mme2/models/half_plus_two/model/00000124/saved_model.pb
new file mode 100644
index 00000000..c79ebe01
Binary files /dev/null and b/test/resources/mme2/models/half_plus_two/model/00000124/saved_model.pb differ
diff --git a/test/resources/mme2/models/half_plus_two/model/00000124/variables/variables.data-00000-of-00001 b/test/resources/mme2/models/half_plus_two/model/00000124/variables/variables.data-00000-of-00001
new file mode 100644
index 00000000..15b75d6e
Binary files /dev/null and b/test/resources/mme2/models/half_plus_two/model/00000124/variables/variables.data-00000-of-00001 differ
diff --git a/test/resources/mme2/models/half_plus_two/model/00000124/variables/variables.index b/test/resources/mme2/models/half_plus_two/model/00000124/variables/variables.index
new file mode 100644
index 00000000..7ec9fb4f
Binary files /dev/null and b/test/resources/mme2/models/half_plus_two/model/00000124/variables/variables.index differ
diff --git a/test/resources/mme2/models/half_plus_two/model/code/inference.py b/test/resources/mme2/models/half_plus_two/model/code/inference.py
new file mode 100644
index 00000000..95b979da
--- /dev/null
+++ b/test/resources/mme2/models/half_plus_two/model/code/inference.py
@@ -0,0 +1,59 @@
+# Copyright 2018-2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"). You
+# may not use this file except in compliance with the License. A copy of
+# the License is located at
+#
+#     http://aws.amazon.com/apache2.0/
+#
+# or in the "license" file accompanying this file. This file is
+# distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
+# ANY KIND, either express or implied. See the License for the specific
+# language governing permissions and limitations under the License.
+
+import json
+from collections import namedtuple
+
+import PIL
+
+Context = namedtuple('Context',
+                     'model_name, model_version, method, rest_uri, grpc_uri, '
+                     'custom_attributes, request_content_type, accept_header')
+
+
+def input_handler(data, context):
+    """ Pre-process request input before it is sent to TensorFlow Serving REST API
+
+    Args:
+        data (obj): the request data, in format of dict or string
+        context (Context): an object containing request and configuration details
+
+    Returns:
+        (dict): a JSON-serializable dict that contains request body and headers
+    """
+    if context.request_content_type == 'text/csv':
+        # very simple csv handler
+        return json.dumps({
+            'instances': [float(x) for x in data.read().decode('utf-8').split(',')]
+        })
+
+    raise ValueError('{{"error": "unsupported content type {}"}}'.format(
+        context.request_content_type or "unknown"))
+
+
+def output_handler(data, context):
+    """Post-process TensorFlow Serving output before it is returned to the client.
+
+    Args:
+        data (obj): the TensorFlow serving response
+        context (Context): an object containing request and configuration details
+
+    Returns:
+        (bytes, string): data to return to client, response content type
+    """
+    if data.status_code != 200:
+        raise ValueError(data.content.decode('utf-8'))
+
+    response_content_type = context.accept_header
+    prediction = data.content
+    return prediction, response_content_type
diff --git a/test/resources/mme3/code/inference.py b/test/resources/mme3/code/inference.py
new file mode 100644
index 00000000..9c6d1d37
--- /dev/null
+++ b/test/resources/mme3/code/inference.py
@@ -0,0 +1,70 @@
+# Copyright 2018-2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"). You
+# may not use this file except in compliance with the License. A copy of
+# the License is located at
+#
+#     http://aws.amazon.com/apache2.0/
+#
+# or in the "license" file accompanying this file. This file is
+# distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
+# ANY KIND, either express or implied. See the License for the specific
+# language governing permissions and limitations under the License.
+
+
+import json
+from collections import namedtuple
+
+import requests
+
+import dummy_module  # for testing requirements.txt install and pythonpath
+
+Context = namedtuple('Context',
+                     'model_name, model_version, method, rest_uri, grpc_uri, '
+                     'custom_attributes, request_content_type, accept_header')
+
+
+def handler(data, context):
+    """Handle request.
+
+    Args:
+        data (obj): the request data
+        context (Context): an object containing request and configuration details
+
+    Returns:
+        (bytes, string): data to return to client, (optional) response content type
+    """
+
+    # use the library in lib/
+    print(dummy_module.__version__)
+
+    # ensure the requirements.txt wasn't installed
+    try:
+        import PIL
+        raise Exception('pillow should not be installed')
+    except ImportError:
+        pass
+
+    processed_input = _process_input(data, context)
+    response = requests.post(context.rest_uri, data=processed_input)
+    return _process_output(response, context)
+
+
+def _process_input(data, context):
+    if context.request_content_type == 'text/csv':
+        # very simple csv handler
+        return json.dumps({
+            'instances': [float(x) for x in data.read().decode('utf-8').split(',')]
+        })
+
+    raise ValueError('{{"error": "unsupported content type {}"}}'.format(
+        context.request_content_type or "unknown"))
+
+
+def _process_output(data, context):
+    if data.status_code != 200:
+        raise ValueError(data.content.decode('utf-8'))
+
+    response_content_type = context.accept_header
+    prediction = data.content
+    return prediction, response_content_type
diff --git a/test/resources/mme3/code/lib/dummy_module/__init__.py b/test/resources/mme3/code/lib/dummy_module/__init__.py
new file mode 100644
index 00000000..11d27f8c
--- /dev/null
+++ b/test/resources/mme3/code/lib/dummy_module/__init__.py
@@ -0,0 +1 @@
+__version__ = '0.1'
diff --git a/test/resources/mme3/code/requirements.txt b/test/resources/mme3/code/requirements.txt
new file mode 100644
index 00000000..2f34b076
--- /dev/null
+++ b/test/resources/mme3/code/requirements.txt
@@ -0,0 +1 @@
+Pillow>=6.2.2
\ No newline at end of file
diff --git a/test/resources/mme3/models/half_plus_three/model/00000123/assets/foo.txt b/test/resources/mme3/models/half_plus_three/model/00000123/assets/foo.txt
new file mode 100644
index 00000000..f9ff0366
--- /dev/null
+++ b/test/resources/mme3/models/half_plus_three/model/00000123/assets/foo.txt
@@ -0,0 +1 @@
+asset-file-contents
\ No newline at end of file
diff --git a/test/resources/mme3/models/half_plus_three/model/00000123/saved_model.pb b/test/resources/mme3/models/half_plus_three/model/00000123/saved_model.pb
new file mode 100644
index 00000000..71ac8582
Binary files /dev/null and b/test/resources/mme3/models/half_plus_three/model/00000123/saved_model.pb differ
diff --git a/test/resources/mme3/models/half_plus_three/model/00000123/variables/variables.data-00000-of-00001 b/test/resources/mme3/models/half_plus_three/model/00000123/variables/variables.data-00000-of-00001
new file mode 100644
index 00000000..74cf8663
Binary files /dev/null and b/test/resources/mme3/models/half_plus_three/model/00000123/variables/variables.data-00000-of-00001 differ
diff --git a/test/resources/mme3/models/half_plus_three/model/00000123/variables/variables.index b/test/resources/mme3/models/half_plus_three/model/00000123/variables/variables.index
new file mode 100644
index 00000000..ac030a9d
Binary files /dev/null and b/test/resources/mme3/models/half_plus_three/model/00000123/variables/variables.index differ
diff --git a/test/resources/mme3/models/half_plus_three/model/00000124/assets/foo.txt b/test/resources/mme3/models/half_plus_three/model/00000124/assets/foo.txt
new file mode 100644
index 00000000..56c3e54a
--- /dev/null
+++ b/test/resources/mme3/models/half_plus_three/model/00000124/assets/foo.txt
@@ -0,0 +1 @@
+asset-file-contents
diff --git a/test/resources/mme3/models/half_plus_three/model/00000124/saved_model.pb b/test/resources/mme3/models/half_plus_three/model/00000124/saved_model.pb
new file mode 100644
index 00000000..71ac8582
Binary files /dev/null and b/test/resources/mme3/models/half_plus_three/model/00000124/saved_model.pb differ
diff --git a/test/resources/mme3/models/half_plus_three/model/00000124/variables/variables.data-00000-of-00001 b/test/resources/mme3/models/half_plus_three/model/00000124/variables/variables.data-00000-of-00001
new file mode 100644
index 00000000..74cf8663
Binary files /dev/null and b/test/resources/mme3/models/half_plus_three/model/00000124/variables/variables.data-00000-of-00001 differ
diff --git a/test/resources/mme3/models/half_plus_three/model/00000124/variables/variables.index b/test/resources/mme3/models/half_plus_three/model/00000124/variables/variables.index
new file mode 100644
index 00000000..ac030a9d
Binary files /dev/null and b/test/resources/mme3/models/half_plus_three/model/00000124/variables/variables.index differ
diff --git a/test/resources/mme3/models/half_plus_three/model/__init__.py b/test/resources/mme3/models/half_plus_three/model/__init__.py
new file mode 100644
index 00000000..e69de29b
diff --git a/test/resources/mme3/models/half_plus_three/model/code/__init__.py b/test/resources/mme3/models/half_plus_three/model/code/__init__.py
new file mode 100644
index 00000000..e69de29b
diff --git a/test/resources/mme3/models/half_plus_three/model/code/inference.py b/test/resources/mme3/models/half_plus_three/model/code/inference.py
new file mode 100644
index 00000000..fd12f017
--- /dev/null
+++ b/test/resources/mme3/models/half_plus_three/model/code/inference.py
@@ -0,0 +1,69 @@
+# Copyright 2018-2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"). You
+# may not use this file except in compliance with the License. A copy of
+# the License is located at
+#
+#     http://aws.amazon.com/apache2.0/
+#
+# or in the "license" file accompanying this file. This file is
+# distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
+# ANY KIND, either express or implied. See the License for the specific
+# language governing permissions and limitations under the License.
+
+
+import json
+from collections import namedtuple
+
+import requests
+
+import dummy_module  # for testing requirements.txt install and pythonpath
+
+Context = namedtuple('Context',
+                     'model_name, model_version, method, rest_uri, grpc_uri, '
+                     'custom_attributes, request_content_type, accept_header')
+
+
+def handler(data, context):
+    """Handle request.
+
+    Args:
+        data (obj): the request data
+        context (Context): an object containing request and configuration details
+
+    Returns:
+        (bytes, string): data to return to client, (optional) response content type
+    """
+
+    # use the library in lib/
+    print(dummy_module.__version__)
+
+    # ensure the requirements.txt wasn't installed
+    try:
+        import PIL
+        raise Exception('pillow should not be installed')
+    except ImportError:
+        pass
+
+    processed_input = _process_input(data, context)
+    response = requests.post(context.rest_uri, data=processed_input)
+    return _process_output(response, context)
+
+
+def _process_input(data, context):
+    if context.request_content_type == 'application/json':
+        # pass through json (assumes it's correctly formed)
+        d = data.read().decode('utf-8')
+        return d if len(d) else ''
+
+    raise ValueError('{{"error": "unsupported content type {}"}}'.format(
+        context.request_content_type or "unknown"))
+
+
+def _process_output(data, context):
+    if data.status_code != 200:
+        raise ValueError(data.content.decode('utf-8'))
+
+    response_content_type = context.accept_header
+    prediction = data.content
+    return prediction, response_content_type
diff --git a/test/resources/mme3/models/half_plus_three/model/code/lib/__init__.py b/test/resources/mme3/models/half_plus_three/model/code/lib/__init__.py
new file mode 100644
index 00000000..e69de29b
diff --git a/test/resources/mme3/models/half_plus_three/model/code/lib/dummy_module/__init__.py b/test/resources/mme3/models/half_plus_three/model/code/lib/dummy_module/__init__.py
new file mode 100644
index 00000000..11d27f8c
--- /dev/null
+++ b/test/resources/mme3/models/half_plus_three/model/code/lib/dummy_module/__init__.py
@@ -0,0 +1 @@
+__version__ = '0.1'
diff --git a/test/resources/mme3/models/half_plus_two/model/00000123/saved_model.pb b/test/resources/mme3/models/half_plus_two/model/00000123/saved_model.pb
new file mode 100644
index 00000000..c79ebe01
Binary files /dev/null and b/test/resources/mme3/models/half_plus_two/model/00000123/saved_model.pb differ
diff --git a/test/resources/mme3/models/half_plus_two/model/00000123/variables/variables.data-00000-of-00001 b/test/resources/mme3/models/half_plus_two/model/00000123/variables/variables.data-00000-of-00001
new file mode 100644
index 00000000..15b75d6e
Binary files /dev/null and b/test/resources/mme3/models/half_plus_two/model/00000123/variables/variables.data-00000-of-00001 differ
diff --git a/test/resources/mme3/models/half_plus_two/model/00000123/variables/variables.index b/test/resources/mme3/models/half_plus_two/model/00000123/variables/variables.index
new file mode 100644
index 00000000..7ec9fb4f
Binary files /dev/null and b/test/resources/mme3/models/half_plus_two/model/00000123/variables/variables.index differ
diff --git a/test/resources/mme3/models/half_plus_two/model/00000124/saved_model.pb b/test/resources/mme3/models/half_plus_two/model/00000124/saved_model.pb
new file mode 100644
index 00000000..c79ebe01
Binary files /dev/null and b/test/resources/mme3/models/half_plus_two/model/00000124/saved_model.pb differ
diff --git a/test/resources/mme3/models/half_plus_two/model/00000124/variables/variables.data-00000-of-00001 b/test/resources/mme3/models/half_plus_two/model/00000124/variables/variables.data-00000-of-00001
new file mode 100644
index 00000000..15b75d6e
Binary files /dev/null and b/test/resources/mme3/models/half_plus_two/model/00000124/variables/variables.data-00000-of-00001 differ
diff --git a/test/resources/mme3/models/half_plus_two/model/00000124/variables/variables.index b/test/resources/mme3/models/half_plus_two/model/00000124/variables/variables.index
new file mode 100644
index 00000000..7ec9fb4f
Binary files /dev/null and b/test/resources/mme3/models/half_plus_two/model/00000124/variables/variables.index differ
diff --git a/test/resources/mme4/models/half_plus_three/model/00000123/assets/foo.txt b/test/resources/mme4/models/half_plus_three/model/00000123/assets/foo.txt
new file mode 100644
index 00000000..f9ff0366
--- /dev/null
+++ b/test/resources/mme4/models/half_plus_three/model/00000123/assets/foo.txt
@@ -0,0 +1 @@
+asset-file-contents
\ No newline at end of file
diff --git a/test/resources/mme4/models/half_plus_three/model/00000123/saved_model.pb b/test/resources/mme4/models/half_plus_three/model/00000123/saved_model.pb
new file mode 100644
index 00000000..71ac8582
Binary files /dev/null and b/test/resources/mme4/models/half_plus_three/model/00000123/saved_model.pb differ
diff --git a/test/resources/mme4/models/half_plus_three/model/00000123/variables/variables.data-00000-of-00001 b/test/resources/mme4/models/half_plus_three/model/00000123/variables/variables.data-00000-of-00001
new file mode 100644
index 00000000..74cf8663
Binary files /dev/null and b/test/resources/mme4/models/half_plus_three/model/00000123/variables/variables.data-00000-of-00001 differ
diff --git a/test/resources/mme4/models/half_plus_three/model/00000123/variables/variables.index b/test/resources/mme4/models/half_plus_three/model/00000123/variables/variables.index
new file mode 100644
index 00000000..ac030a9d
Binary files /dev/null and b/test/resources/mme4/models/half_plus_three/model/00000123/variables/variables.index differ
diff --git a/test/resources/mme4/models/half_plus_three/model/00000124/assets/foo.txt b/test/resources/mme4/models/half_plus_three/model/00000124/assets/foo.txt
new file mode 100644
index 00000000..56c3e54a
--- /dev/null
+++ b/test/resources/mme4/models/half_plus_three/model/00000124/assets/foo.txt
@@ -0,0 +1 @@
+asset-file-contents
diff --git a/test/resources/mme4/models/half_plus_three/model/00000124/saved_model.pb b/test/resources/mme4/models/half_plus_three/model/00000124/saved_model.pb
new file mode 100644
index 00000000..71ac8582
Binary files /dev/null and b/test/resources/mme4/models/half_plus_three/model/00000124/saved_model.pb differ
diff --git a/test/resources/mme4/models/half_plus_three/model/00000124/variables/variables.data-00000-of-00001 b/test/resources/mme4/models/half_plus_three/model/00000124/variables/variables.data-00000-of-00001
new file mode 100644
index 00000000..74cf8663
Binary files /dev/null and b/test/resources/mme4/models/half_plus_three/model/00000124/variables/variables.data-00000-of-00001 differ
diff --git a/test/resources/mme4/models/half_plus_three/model/00000124/variables/variables.index b/test/resources/mme4/models/half_plus_three/model/00000124/variables/variables.index
new file mode 100644
index 00000000..ac030a9d
Binary files /dev/null and b/test/resources/mme4/models/half_plus_three/model/00000124/variables/variables.index differ
diff --git a/test/resources/mme4/models/half_plus_three/model/__init__.py b/test/resources/mme4/models/half_plus_three/model/__init__.py
new file mode 100644
index 00000000..e69de29b
diff --git a/test/resources/mme4/models/half_plus_three/model/code/__init__.py b/test/resources/mme4/models/half_plus_three/model/code/__init__.py
new file mode 100644
index 00000000..e69de29b
diff --git a/test/resources/mme4/models/half_plus_three/model/code/inference.py b/test/resources/mme4/models/half_plus_three/model/code/inference.py
new file mode 100644
index 00000000..f598a30a
--- /dev/null
+++ b/test/resources/mme4/models/half_plus_three/model/code/inference.py
@@ -0,0 +1,75 @@
+# Copyright 2018-2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"). You
+# may not use this file except in compliance with the License. A copy of
+# the License is located at
+#
+#     http://aws.amazon.com/apache2.0/
+#
+# or in the "license" file accompanying this file. This file is
+# distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
+# ANY KIND, either express or implied. See the License for the specific
+# language governing permissions and limitations under the License.
+
+
+import json
+from collections import namedtuple
+
+import requests
+
+import dummy_module  # for testing requirements.txt install and pythonpath
+
+Context = namedtuple('Context',
+                     'model_name, model_version, method, rest_uri, grpc_uri, '
+                     'custom_attributes, request_content_type, accept_header')
+
+
+def handler(data, context):
+    """Handle request.
+
+    Args:
+        data (obj): the request data
+        context (Context): an object containing request and configuration details
+
+    Returns:
+        (bytes, string): data to return to client, (optional) response content type
+    """
+
+    # use the library in lib/
+    print(dummy_module.__version__)
+
+    # ensure the requirements.txt wasn't installed
+    try:
+        import PIL
+        raise Exception('pillow should not be installed')
+    except ImportError:
+        pass
+
+    processed_input = _process_input(data, context)
+    response = requests.post(context.rest_uri, data=processed_input)
+    return _process_output(response, context)
+
+
+def _process_input(data, context):
+    if context.request_content_type == 'application/json':
+        # pass through json (assumes it's correctly formed)
+        d = data.read().decode('utf-8')
+        return d if len(d) else ''
+
+    if context.request_content_type == 'text/csv':
+        # very simple csv handler
+        return json.dumps({
+            'instances': [float(x) for x in data.read().decode('utf-8').split(',')]
+        })
+
+    raise ValueError('{{"error": "unsupported content type {}"}}'.format(
+        context.request_content_type or "unknown"))
+
+
+def _process_output(data, context):
+    if data.status_code != 200:
+        raise ValueError(data.content.decode('utf-8'))
+
+    response_content_type = context.accept_header
+    prediction = data.content
+    return prediction, response_content_type
diff --git a/test/resources/mme4/models/half_plus_three/model/code/lib/__init__.py b/test/resources/mme4/models/half_plus_three/model/code/lib/__init__.py
new file mode 100644
index 00000000..e69de29b
diff --git a/test/resources/mme4/models/half_plus_three/model/code/lib/dummy_module/__init__.py b/test/resources/mme4/models/half_plus_three/model/code/lib/dummy_module/__init__.py
new file mode 100644
index 00000000..11d27f8c
--- /dev/null
+++ b/test/resources/mme4/models/half_plus_three/model/code/lib/dummy_module/__init__.py
@@ -0,0 +1 @@
+__version__ = '0.1'
diff --git a/test/resources/mme4/models/half_plus_two/model/00000123/saved_model.pb b/test/resources/mme4/models/half_plus_two/model/00000123/saved_model.pb
new file mode 100644
index 00000000..c79ebe01
Binary files /dev/null and b/test/resources/mme4/models/half_plus_two/model/00000123/saved_model.pb differ
diff --git a/test/resources/mme4/models/half_plus_two/model/00000123/variables/variables.data-00000-of-00001 b/test/resources/mme4/models/half_plus_two/model/00000123/variables/variables.data-00000-of-00001
new file mode 100644
index 00000000..15b75d6e
Binary files /dev/null and b/test/resources/mme4/models/half_plus_two/model/00000123/variables/variables.data-00000-of-00001 differ
diff --git a/test/resources/mme4/models/half_plus_two/model/00000123/variables/variables.index b/test/resources/mme4/models/half_plus_two/model/00000123/variables/variables.index
new file mode 100644
index 00000000..7ec9fb4f
Binary files /dev/null and b/test/resources/mme4/models/half_plus_two/model/00000123/variables/variables.index differ
diff --git a/test/resources/mme4/models/half_plus_two/model/00000124/saved_model.pb b/test/resources/mme4/models/half_plus_two/model/00000124/saved_model.pb
new file mode 100644
index 00000000..c79ebe01
Binary files /dev/null and b/test/resources/mme4/models/half_plus_two/model/00000124/saved_model.pb differ
diff --git a/test/resources/mme4/models/half_plus_two/model/00000124/variables/variables.data-00000-of-00001 b/test/resources/mme4/models/half_plus_two/model/00000124/variables/variables.data-00000-of-00001
new file mode 100644
index 00000000..15b75d6e
Binary files /dev/null and b/test/resources/mme4/models/half_plus_two/model/00000124/variables/variables.data-00000-of-00001 differ
diff --git a/test/resources/mme4/models/half_plus_two/model/00000124/variables/variables.index b/test/resources/mme4/models/half_plus_two/model/00000124/variables/variables.index
new file mode 100644
index 00000000..7ec9fb4f
Binary files /dev/null and b/test/resources/mme4/models/half_plus_two/model/00000124/variables/variables.index differ