in aws-mwaa-environment/src/main/java/software/amazon/mwaa/environment/UpdateHandler.java [154:172]
private void removeTags(final ProxyClient<MwaaClient> mwaaClientProxy,
final TagProcessor tagProcessor,
final String arn,
final Map<String, String> desiredTags) {
final Collection<String> tagsToRemove = tagProcessor.getTagsToRemove(desiredTags);
log("Tags to remove: %s", collectionToLogString(tagsToRemove));
if (tagsToRemove.isEmpty()) {
return;
}
log("Untagging...");
mwaaClientProxy.injectCredentialsAndInvokeV2(
UntagResourceRequest.builder()
.resourceArn(arn)
.tagKeys(tagsToRemove)
.build(),
mwaaClientProxy.client()::untagResource);
log("Untagging done");
}