@@ -139,12 +139,15 @@ def test_downstream_artifacts(static_approval_action):
139139
140140
141141def test_datasets (static_approval_action , static_dataset_artifact , sagemaker_session ):
142+ try :
143+ sagemaker_session .sagemaker_client .add_association (
144+ SourceArn = static_dataset_artifact .artifact_arn ,
145+ DestinationArn = static_approval_action .action_arn ,
146+ AssociationType = "ContributedTo" ,
147+ )
148+ except Exception :
149+ print ("Source and Destination association already exists." )
142150
143- sagemaker_session .sagemaker_client .add_association (
144- SourceArn = static_dataset_artifact .artifact_arn ,
145- DestinationArn = static_approval_action .action_arn ,
146- AssociationType = "ContributedTo" ,
147- )
148151 time .sleep (3 )
149152 artifacts_from_query = static_approval_action .datasets ()
150153
@@ -153,10 +156,13 @@ def test_datasets(static_approval_action, static_dataset_artifact, sagemaker_ses
153156 assert "artifact" in artifact .artifact_arn
154157 assert artifact .artifact_type == "DataSet"
155158
156- sagemaker_session .sagemaker_client .delete_association (
157- SourceArn = static_dataset_artifact .artifact_arn ,
158- DestinationArn = static_approval_action .action_arn ,
159- )
159+ try :
160+ sagemaker_session .sagemaker_client .delete_association (
161+ SourceArn = static_dataset_artifact .artifact_arn ,
162+ DestinationArn = static_approval_action .action_arn ,
163+ )
164+ except Exception :
165+ pass
160166
161167
162168def test_endpoints (static_approval_action ):
0 commit comments