Skip to content

Commit

Permalink
fix(ecs): rename capacityProviderStrategies to capacityProviderStrate…
Browse files Browse the repository at this point in the history
…gy to align with CreateService api (#5154)
  • Loading branch information
piradeepk committed Dec 11, 2020
1 parent baf84c4 commit 3b101cc
Show file tree
Hide file tree
Showing 6 changed files with 22 additions and 22 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
"credentials": "ecs-account",
"dockerImageAddress": "nginx",
"ecsClusterName": "integArtifactsFargateCapacityProviderStrategy-cluster",
"capacityProviderStrategies": [
"capacityProviderStrategy": [
{
"capacityProvider": "FARGATE",
"weight": 1
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ public class CreateServerGroupDescription extends AbstractECSDescription {

Set<TargetGroupProperties> targetGroupMappings;

List<CapacityProviderStrategyItem> capacityProviderStrategies;
List<CapacityProviderStrategyItem> capacityProviderStrategy;

@Override
public String getRegion() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -317,10 +317,10 @@ protected RegisterTaskDefinitionRequest makeTaskDefinitionRequest(
}
}

if (description.getCapacityProviderStrategies() != null
&& !description.getCapacityProviderStrategies().isEmpty()) {
if (description.getCapacityProviderStrategy() != null
&& !description.getCapacityProviderStrategy().isEmpty()) {

for (CapacityProviderStrategyItem cpStrategy : description.getCapacityProviderStrategies()) {
for (CapacityProviderStrategyItem cpStrategy : description.getCapacityProviderStrategy()) {
if (FARGATE.equals(cpStrategy.getCapacityProvider())
|| FARGATE_SPOT.equals(cpStrategy.getCapacityProvider())) {
request.setRequiresCompatibilities(Arrays.asList(FARGATE));
Expand Down Expand Up @@ -407,9 +407,9 @@ protected RegisterTaskDefinitionRequest makeTaskDefinitionRequestFromArtifact(
if (templateExecutionRole == null || templateExecutionRole.isEmpty()) {
requestTemplate.setExecutionRoleArn(ecsServiceRole);
}
} else if (description.getCapacityProviderStrategies() != null
&& !description.getCapacityProviderStrategies().isEmpty()) {
for (CapacityProviderStrategyItem cpStrategy : description.getCapacityProviderStrategies()) {
} else if (description.getCapacityProviderStrategy() != null
&& !description.getCapacityProviderStrategy().isEmpty()) {
for (CapacityProviderStrategyItem cpStrategy : description.getCapacityProviderStrategy()) {
if (FARGATE.equals(cpStrategy.getCapacityProvider())
|| FARGATE_SPOT.equals(cpStrategy.getCapacityProvider())) {
String templateExecutionRole = requestTemplate.getExecutionRoleArn();
Expand Down Expand Up @@ -605,9 +605,9 @@ public List<Tag> getResourceTags() {

if (!StringUtils.isEmpty(description.getLaunchType())) {
request.withLaunchType(description.getLaunchType());
} else if (description.getCapacityProviderStrategies() != null
&& !description.getCapacityProviderStrategies().isEmpty()) {
request.withCapacityProviderStrategy(description.getCapacityProviderStrategies());
} else if (description.getCapacityProviderStrategy() != null
&& !description.getCapacityProviderStrategy().isEmpty()) {
request.withCapacityProviderStrategy(description.getCapacityProviderStrategy());
}

if (!StringUtils.isEmpty(description.getPlatformVersion())) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -201,20 +201,20 @@ public void validate(List priorDescriptions, Object description, ValidationError

private void validateComputeOptions(
CreateServerGroupDescription createServerGroupDescription, ValidationErrors errors) {
if (createServerGroupDescription.getCapacityProviderStrategies() != null
&& !createServerGroupDescription.getCapacityProviderStrategies().isEmpty()) {
if (createServerGroupDescription.getCapacityProviderStrategy() != null
&& !createServerGroupDescription.getCapacityProviderStrategy().isEmpty()) {
if (!StringUtils.isBlank(createServerGroupDescription.getLaunchType())) {
errors.rejectValue(
"launchType",
errorKey + "." + "launchType" + "." + "invalid",
"LaunchType cannot be specified when CapacityProviderStrategies are specified.");
"LaunchType cannot be specified when CapacityProviderStrategy are specified.");
}
} else if (createServerGroupDescription.getCapacityProviderStrategies() == null
} else if (createServerGroupDescription.getCapacityProviderStrategy() == null
&& StringUtils.isBlank(createServerGroupDescription.getLaunchType())) {
errors.rejectValue(
"launchType",
errorKey + "." + "launchType" + "." + "invalid",
"LaunchType or CapacityProviderStrategies must be specified.");
"LaunchType or CapacityProviderStrategy must be specified.");
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -343,7 +343,7 @@ class CreateServerGroupAtomicOperationSpec extends CommonAtomicOperation {
capacity: new ServerGroup.Capacity(1, 1, 1),
availabilityZones: ['us-west-1': ['us-west-1a', 'us-west-1b', 'us-west-1c']],
placementStrategySequence: [],
capacityProviderStrategies: [capacityProviderStrategy],
capacityProviderStrategy: [capacityProviderStrategy],
platformVersion: '1.0.0',
networkMode: 'awsvpc',
subnetType: 'public',
Expand Down Expand Up @@ -789,7 +789,7 @@ class CreateServerGroupAtomicOperationSpec extends CommonAtomicOperation {
description.getFreeFormDetails() >> 'test'
description.getEcsClusterName() >> 'test-cluster'
description.getIamRole() >> 'None (No IAM role)'
description.getCapacityProviderStrategies() >> [capacityProviderStrategy]
description.getCapacityProviderStrategy() >> [capacityProviderStrategy]
description.getResolvedTaskDefinitionArtifact() >> resolvedArtifact
description.getContainerToImageMap() >> [
web: "docker-image-url"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -191,29 +191,29 @@ class EcsCreateServergroupDescriptionValidatorSpec extends AbstractValidatorSpec
weight: 1
)
def description = getDescription()
description.capacityProviderStrategies = [capacityProviderStrategy]
description.capacityProviderStrategy = [capacityProviderStrategy]
description.launchType = 'FARGATE'
def errors = Mock(ValidationErrors)

when:
validator.validate([], description, errors)

then:
1 * errors.rejectValue('launchType', 'createServerGroupDescription.launchType.invalid', 'LaunchType cannot be specified when CapacityProviderStrategies are specified.')
1 * errors.rejectValue('launchType', 'createServerGroupDescription.launchType.invalid', 'LaunchType cannot be specified when CapacityProviderStrategy are specified.')
}

void 'should fail when neither launch type or capacity provider strategy are defined'() {
given:
def description = getDescription()
description.capacityProviderStrategies = null
description.capacityProviderStrategy = null
description.launchType = null
def errors = Mock(ValidationErrors)

when:
validator.validate([], description, errors)

then:
1 * errors.rejectValue('launchType', 'createServerGroupDescription.launchType.invalid', 'LaunchType or CapacityProviderStrategies must be specified.')
1 * errors.rejectValue('launchType', 'createServerGroupDescription.launchType.invalid', 'LaunchType or CapacityProviderStrategy must be specified.')
}

void 'target group mappings should fail when container name is specified but load balancer is missing'() {
Expand Down

0 comments on commit 3b101cc

Please sign in to comment.