@@ -146,14 +146,14 @@ def test_mnist_async(sagemaker_session):
146
146
training_job_name = estimator .latest_training_job .name
147
147
time .sleep (20 )
148
148
endpoint_name = training_job_name
149
- model_name = "model-name-1"
150
149
_assert_training_job_tags_match (
151
150
sagemaker_session .sagemaker_client , estimator .latest_training_job .name , TAGS
152
151
)
153
152
with tests .integ .timeout .timeout_and_delete_endpoint_by_name (endpoint_name , sagemaker_session ):
154
153
estimator = TensorFlow .attach (
155
154
training_job_name = training_job_name , sagemaker_session = sagemaker_session
156
155
)
156
+ model_name = "model-mnist-async"
157
157
predictor = estimator .deploy (
158
158
initial_instance_count = 1 ,
159
159
instance_type = "ml.c4.xlarge" ,
@@ -215,14 +215,14 @@ def _assert_s3_files_exist(s3_url, files):
215
215
raise ValueError ("File {} is not found under {}" .format (f , s3_url ))
216
216
217
217
218
- def _assert_tags_match (sagemaker_client , resource_arn , tags , retries = 1 ):
218
+ def _assert_tags_match (sagemaker_client , resource_arn , tags , retries = 15 ):
219
219
actual_tags = None
220
220
for _ in range (retries ):
221
221
actual_tags = sagemaker_client .list_tags (ResourceArn = resource_arn )["Tags" ]
222
222
if actual_tags :
223
223
break
224
224
else :
225
- # endpoint tags might take minutes to propagate. Sleeping.
225
+ # endpoint and training tags might take minutes to propagate. Sleeping.
226
226
time .sleep (30 )
227
227
assert actual_tags == tags
228
228
@@ -235,7 +235,7 @@ def _assert_model_tags_match(sagemaker_client, model_name, tags):
235
235
def _assert_endpoint_tags_match (sagemaker_client , endpoint_name , tags ):
236
236
endpoint_description = sagemaker_client .describe_endpoint (EndpointName = endpoint_name )
237
237
238
- _assert_tags_match (sagemaker_client , endpoint_description ["EndpointArn" ], tags , retries = 10 )
238
+ _assert_tags_match (sagemaker_client , endpoint_description ["EndpointArn" ], tags )
239
239
240
240
241
241
def _assert_training_job_tags_match (sagemaker_client , training_job_name , tags ):
0 commit comments