Skip to content

Commit

Permalink
Revert "support region wellknown label"
Browse files Browse the repository at this point in the history
This reverts commit 2aaada8.
  • Loading branch information
bwagner5 committed Jan 28, 2022
1 parent 0c1f5e2 commit f345a6c
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 16 deletions.
14 changes: 4 additions & 10 deletions pkg/apis/provisioning/v1alpha5/requirements.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,6 @@ var (
// WellKnownLabels supported by karpenter
WellKnownLabels = sets.NewString(
v1.LabelTopologyZone,
v1.LabelTopologyRegion,
v1.LabelInstanceTypeStable,
v1.LabelArchStable,
v1.LabelOSStable,
Expand All @@ -64,11 +63,10 @@ var (
// however, Provisioner labels are still restricted to WellKnownLabels.
// Additional labels may be injected by cloud providers.
NormalizedLabels = map[string]string{
v1.LabelFailureDomainBetaZone: v1.LabelTopologyZone,
v1.LabelFailureDomainBetaRegion: v1.LabelTopologyRegion,
"beta.kubernetes.io/arch": v1.LabelArchStable,
"beta.kubernetes.io/os": v1.LabelOSStable,
v1.LabelInstanceType: v1.LabelInstanceTypeStable,
v1.LabelFailureDomainBetaZone: v1.LabelTopologyZone,
"beta.kubernetes.io/arch": v1.LabelArchStable,
"beta.kubernetes.io/os": v1.LabelOSStable,
v1.LabelInstanceType: v1.LabelInstanceTypeStable,
}
)

Expand All @@ -79,10 +77,6 @@ func (r Requirements) Zones() sets.String {
return r.Requirement(v1.LabelTopologyZone)
}

func (r Requirements) Regions() sets.String {
return r.Requirement(v1.LabelTopologyRegion)
}

func (r Requirements) InstanceTypes() sets.String {
return r.Requirement(v1.LabelInstanceTypeStable)
}
Expand Down
6 changes: 2 additions & 4 deletions pkg/cloudprovider/aws/instance.go
Original file line number Diff line number Diff line change
Expand Up @@ -249,19 +249,17 @@ func (p *InstanceProvider) instanceToNode(ctx context.Context, instance *ec2.Ins
if injection.GetOptions(ctx).GetAWSNodeNameConvention() == options.ResourceName {
nodeName = aws.StringValue(instance.InstanceId)
}
zone := aws.StringValue(instance.Placement.AvailabilityZone)
return &v1.Node{
ObjectMeta: metav1.ObjectMeta{
Name: nodeName,
Labels: map[string]string{
v1.LabelTopologyZone: zone,
v1.LabelTopologyRegion: zone[:len(zone)-1],
v1.LabelTopologyZone: aws.StringValue(instance.Placement.AvailabilityZone),
v1.LabelInstanceTypeStable: aws.StringValue(instance.InstanceType),
v1alpha5.LabelCapacityType: getCapacityType(instance),
},
},
Spec: v1.NodeSpec{
ProviderID: fmt.Sprintf("aws:///%s/%s", zone, aws.StringValue(instance.InstanceId)),
ProviderID: fmt.Sprintf("aws:///%s/%s", aws.StringValue(instance.Placement.AvailabilityZone), aws.StringValue(instance.InstanceId)),
},
Status: v1.NodeStatus{
Allocatable: v1.ResourceList{
Expand Down
3 changes: 1 addition & 2 deletions pkg/cloudprovider/aws/instancetypes.go
Original file line number Diff line number Diff line change
Expand Up @@ -17,10 +17,9 @@ package aws
import (
"context"
"fmt"
"time"

"github.com/aws/karpenter/pkg/utils/injection"
"knative.dev/pkg/ptr"
"time"

"github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/service/ec2"
Expand Down

0 comments on commit f345a6c

Please sign in to comment.