From f0b68cb44ba0fbdfee1883c04d82698f8f3f8cec Mon Sep 17 00:00:00 2001 From: "M. Mert Yildiran" Date: Wed, 15 Feb 2023 22:33:59 +0300 Subject: [PATCH] :rewind: Revert "Create Worker(s) before Hub" --- cmd/tapRunner.go | 17 +++++++++++++++++ resources/createResources.go | 17 ----------------- 2 files changed, 17 insertions(+), 17 deletions(-) diff --git a/cmd/tapRunner.go b/cmd/tapRunner.go index d82e4ffda..7580e9778 100644 --- a/cmd/tapRunner.go +++ b/cmd/tapRunner.go @@ -409,6 +409,23 @@ func postHubStarted(ctx context.Context, kubernetesProvider *kubernetes.Provider "/echo", ) + // Create workers + err := kubernetes.CreateWorkers( + kubernetesProvider, + state.selfServiceAccountExists, + ctx, + config.Config.SelfNamespace, + config.Config.Tap.Resources.Worker, + config.Config.ImagePullPolicy(), + config.Config.ImagePullSecrets(), + config.Config.Tap.ServiceMesh, + config.Config.Tap.Tls, + config.Config.Tap.Debug, + ) + if err != nil { + log.Error().Err(err).Send() + } + // Storage limit connector.PostStorageLimitToHub(config.Config.Tap.StorageLimitBytes()) diff --git a/resources/createResources.go b/resources/createResources.go index f4cab6e9f..f43d01bf5 100644 --- a/resources/createResources.go +++ b/resources/createResources.go @@ -32,23 +32,6 @@ func CreateHubResources(ctx context.Context, kubernetesProvider *kubernetes.Prov serviceAccountName = "" } - // Create workers - err = kubernetes.CreateWorkers( - kubernetesProvider, - selfServiceAccountExists, - ctx, - config.Config.SelfNamespace, - config.Config.Tap.Resources.Worker, - config.Config.ImagePullPolicy(), - config.Config.ImagePullSecrets(), - config.Config.Tap.ServiceMesh, - config.Config.Tap.Tls, - config.Config.Tap.Debug, - ) - if err != nil { - log.Error().Err(err).Send() - } - opts := &kubernetes.PodOptions{ Namespace: selfNamespace, PodName: kubernetes.HubPodName,