in activity/src/main/java/com/amazonaws/stepfunctions/cloudformation/activity/CreateHandler.java [18:48]
public ProgressEvent<ResourceModel, CallbackContext> handleRequest(
final AmazonWebServicesClientProxy proxy,
final ResourceHandlerRequest<ResourceModel> request,
final CallbackContext callbackContext,
final Logger logger) {
logger.log("INFO Activity CreateHandler with clientRequestToken: " + request.getClientRequestToken());
final ResourceModel model = request.getDesiredResourceState();
try {
AWSStepFunctions sfnClient = ClientBuilder.getClient();
List<Tag> tags = TaggingHelper.consolidateTags(request);
CreateActivityRequest createActivityRequest = new CreateActivityRequest()
.withName(model.getName())
.withTags(tags);
CreateActivityResult createActivityResult = proxy.injectCredentialsAndInvoke(createActivityRequest, sfnClient::createActivity);
model.setArn(createActivityResult.getActivityArn());
return ProgressEvent.<ResourceModel, CallbackContext>builder()
.resourceModel(model)
.status(OperationStatus.SUCCESS)
.build();
} catch (Exception e) {
logger.log("ERROR Creating Activity, caused by " + e.toString());
return handleDefaultError(request, e);
}
}