Skip to content

Commit

Permalink
Update emr_engine.go
Browse files Browse the repository at this point in the history
  • Loading branch information
oz-r authored Jul 17, 2024
1 parent 7caa6f8 commit 4873bc5
Showing 1 changed file with 1 addition and 8 deletions.
9 changes: 1 addition & 8 deletions execution/engine/emr_engine.go
Original file line number Diff line number Diff line change
Expand Up @@ -275,7 +275,7 @@ func generateVolumesForCluster(clusterName string, isEmptyDir bool) ([]v1.Volume
var volumes []v1.Volume
var volumeMounts []v1.VolumeMount

if clusterName == "flotilla-eks-infra-c" || isEmptyDir {
if isEmptyDir {
// Use a emptyDir volume
specificVolume := v1.Volume{
Name: "shared-lib-volume",
Expand Down Expand Up @@ -484,13 +484,6 @@ func (emr *EMRExecutionEngine) constructAffinity(executable state.Executable, ru
nodeArchKey := "kubernetes.io/arch"

newCluster := true
//todo remove post migration
switch run.ClusterName {
case "flotilla-eks-infra-c":
newCluster = false
nodeLifecycleKey = "node.kubernetes.io/lifecycle"
nodeArchKey = "kubernetes.io/arch"
}

arch := []string{"amd64"}
if run.Arch != nil && *run.Arch == "arm64" {
Expand Down

0 comments on commit 4873bc5

Please sign in to comment.