in aws-mwaa-environment/src/main/java/software/amazon/mwaa/environment/UpdateHandler.java [174:192]
private void addTags(final ProxyClient<MwaaClient> mwaaClientProxy,
final TagProcessor tagProcessor,
final String arn,
final Map<String, String> desiredTags) {
final Map<String, String> tagsToAdd = tagProcessor.getTagsToAdd(desiredTags);
log("Tags to add: %s", mapToLogString(tagsToAdd));
if (tagsToAdd.isEmpty()) {
return;
}
log("Tagging...");
mwaaClientProxy.injectCredentialsAndInvokeV2(
TagResourceRequest.builder()
.resourceArn(arn)
.tags(tagsToAdd)
.build(),
mwaaClientProxy.client()::tagResource);
log("Tagging done");
}