@@ -139,12 +139,15 @@ def test_downstream_artifacts(static_approval_action):
139
139
140
140
141
141
def 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." )
142
150
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
151
time .sleep (3 )
149
152
artifacts_from_query = static_approval_action .datasets ()
150
153
@@ -153,10 +156,13 @@ def test_datasets(static_approval_action, static_dataset_artifact, sagemaker_ses
153
156
assert "artifact" in artifact .artifact_arn
154
157
assert artifact .artifact_type == "DataSet"
155
158
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
160
166
161
167
162
168
def test_endpoints (static_approval_action ):
0 commit comments