samples: Add Batch Prediction Job with dedicated resources sample (#396)

Manually tested usage with:
```py
import os
import create_batch_prediction_job_dedicated_resources_sample

bpj = create_batch_prediction_job_dedicated_resources_sample.create_batch_prediction_job_dedicated_resources_sample(
    project=os.getenv("BUILD_SPECIFIC_GCLOUD_PROJECT"),
    location='us-central1',
    model_resource_name='3512561418744365056',
    job_display_name='temp_create_batch_prediction_job_test_manual_vinnys',
    gcs_source='gs://ucaip-samples-test-output/inputs/icn_batch_prediction_input.jsonl',
    gcs_destination='gs://ucaip-samples-test-output/',
)
```

Author: vinnysenthil

samples/model-builder/create_batch_prediction_job_dedicated_resources_sample.py

@@ -0,0 +1,59 @@
+# Copyright 2021 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License 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.
+
+from typing import Sequence, Union
+
+from google.cloud import aiplatform, aiplatform_v1
+
+
+#  [START aiplatform_sdk_create_batch_prediction_job_dedicated_resources_sample]
+def create_batch_prediction_job_dedicated_resources_sample(
+    project: str,
+    location: str,
+    model_resource_name: str,
+    job_display_name: str,
+    gcs_source: Union[str, Sequence[str]],
+    gcs_destination: str,
+    machine_type: str = "n1-standard-2",
+    accelerator_count: int = 1,
+    accelerator_type: Union[str, aiplatform_v1.AcceleratorType] = "NVIDIA_TESLA_K80",
+    starting_replica_count: int = 1,
+    max_replica_count: int = 1,
+    sync: bool = True,
+):
+    aiplatform.init(project=project, location=location)
+
+    my_model = aiplatform.Model(model_resource_name)
+
+    batch_prediction_job = my_model.batch_predict(
+        job_display_name=job_display_name,
+        gcs_source=gcs_source,
+        gcs_destination_prefix=gcs_destination,
+        machine_type=machine_type,
+        accelerator_count=accelerator_count,
+        accelerator_type=accelerator_type,
+        starting_replica_count=starting_replica_count,
+        max_replica_count=max_replica_count,
+        sync=sync,
+    )
+
+    batch_prediction_job.wait()
+
+    print(batch_prediction_job.display_name)
+    print(batch_prediction_job.resource_name)
+    print(batch_prediction_job.state)
+    return batch_prediction_job
+
+
+#  [END aiplatform_sdk_create_batch_prediction_job_dedicated_resources_sample]

samples/model-builder/create_batch_prediction_job_dedicated_resources_sample_test.py

@@ -0,0 +1,55 @@
+# Copyright 2021 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License 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 pytest
+
+import create_batch_prediction_job_dedicated_resources_sample
+import test_constants as constants
+
+
+@pytest.mark.usefixtures("mock_model")
+def test_create_batch_prediction_job_sample(
+    mock_sdk_init, mock_init_model, mock_batch_predict_model
+):
+
+    create_batch_prediction_job_dedicated_resources_sample.create_batch_prediction_job_dedicated_resources_sample(
+        project=constants.PROJECT,
+        location=constants.LOCATION,
+        model_resource_name=constants.MODEL_NAME,
+        job_display_name=constants.DISPLAY_NAME,
+        gcs_source=constants.GCS_SOURCES,
+        gcs_destination=constants.GCS_DESTINATION,
+        machine_type=constants.ACCELERATOR_TYPE,
+        accelerator_count=constants.ACCELERATOR_COUNT,
+        accelerator_type=constants.ACCELERATOR_TYPE,
+        starting_replica_count=constants.MIN_REPLICA_COUNT,
+        max_replica_count=constants.MAX_REPLICA_COUNT,
+    )
+
+    mock_sdk_init.assert_called_once_with(
+        project=constants.PROJECT, location=constants.LOCATION
+    )
+    mock_init_model.assert_called_once_with(constants.MODEL_NAME)
+    mock_batch_predict_model.assert_called_once_with(
+        job_display_name=constants.DISPLAY_NAME,
+        gcs_source=constants.GCS_SOURCES,
+        gcs_destination_prefix=constants.GCS_DESTINATION,
+        machine_type=constants.ACCELERATOR_TYPE,
+        accelerator_count=constants.ACCELERATOR_COUNT,
+        accelerator_type=constants.ACCELERATOR_TYPE,
+        starting_replica_count=constants.MIN_REPLICA_COUNT,
+        max_replica_count=constants.MAX_REPLICA_COUNT,
+        sync=True,
+    )