From 045e77e4d5054a3c648444a818fda34b36fc4554 Mon Sep 17 00:00:00 2001 From: LJ <110393214+ukff@users.noreply.github.com> Date: Thu, 5 Dec 2024 10:25:54 +0100 Subject: [PATCH] Set KEB dependecies (#1527) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * wip * wip --------- Co-authored-by: Piotr Miśkiewicz --- internal/error/errors.go | 2 ++ internal/process/deprovisioning/btp_operator_cleanup.go | 2 +- .../deprovisioning/check_gardenercluster_deleted_step.go | 2 +- .../deprovisioning/check_kyma_resource_deleted_step.go | 2 +- internal/process/deprovisioning/check_runtime_removal_step.go | 2 +- .../deprovisioning/check_runtime_resource_deletion_step.go | 2 +- internal/process/deprovisioning/delete_gardener_cluster.go | 2 +- internal/process/deprovisioning/delete_kyma_resource_step.go | 2 +- .../process/deprovisioning/delete_runtime_resource_step.go | 2 +- internal/process/deprovisioning/init.go | 2 +- internal/process/deprovisioning/release_subscription_step.go | 2 +- internal/process/deprovisioning/remove_instance_step.go | 2 +- internal/process/deprovisioning/remove_runtime.go | 2 +- internal/process/provisioning/create_resource_names_step.go | 2 +- internal/process/provisioning/create_runtime_resource_step.go | 2 +- internal/process/provisioning/generate_runtime_id_step.go | 2 +- internal/process/provisioning/get_kubeconfig_step.go | 2 +- internal/process/provisioning/initialisation.go | 2 +- .../provisioning/inject_btp_operator_credentials_step.go | 2 +- internal/process/provisioning/override_kyma_modules.go | 2 +- internal/process/provisioning/resolve_creds.go | 2 +- internal/process/provisioning/start_step.go | 4 +++- internal/process/staged_manager.go | 4 ++-- internal/process/steps/gardener_cluster.go | 4 ++-- internal/process/steps/kyma_template.go | 2 +- internal/process/steps/lifecycle_manager_kubeconfig.go | 4 ++-- internal/process/steps/runtime_resource.go | 2 +- internal/process/update/check_step.go | 2 +- internal/process/update/initialisation_step.go | 2 +- internal/process/update/update_runtime_step.go | 2 +- internal/process/update/upgrade_shoot_step.go | 2 +- 31 files changed, 37 insertions(+), 33 deletions(-) diff --git a/internal/error/errors.go b/internal/error/errors.go index 0e1fa632be..2eaba25283 100644 --- a/internal/error/errors.go +++ b/internal/error/errors.go @@ -51,6 +51,8 @@ const ( ReconcileDependency Component = "reconciler" InfrastructureManagerDependency Component = "infrastructure-manager" LifeCycleManagerDependency Component = "lifecycle-manager" + BtpManagerDependency Component = "btp-manager" + AccountPoolDependency Component = "account-pool" ) func (err LastError) GetReason() Reason { diff --git a/internal/process/deprovisioning/btp_operator_cleanup.go b/internal/process/deprovisioning/btp_operator_cleanup.go index c3c424d1b8..2ac3e6f99e 100644 --- a/internal/process/deprovisioning/btp_operator_cleanup.go +++ b/internal/process/deprovisioning/btp_operator_cleanup.go @@ -44,7 +44,7 @@ func NewBTPOperatorCleanupStep(os storage.Operations, k8sClientProvider K8sClien step := &BTPOperatorCleanupStep{ k8sClientProvider: k8sClientProvider, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.KEBDependency) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.BtpManagerDependency) return step } diff --git a/internal/process/deprovisioning/check_gardenercluster_deleted_step.go b/internal/process/deprovisioning/check_gardenercluster_deleted_step.go index 28502c4478..259bfa1303 100644 --- a/internal/process/deprovisioning/check_gardenercluster_deleted_step.go +++ b/internal/process/deprovisioning/check_gardenercluster_deleted_step.go @@ -30,7 +30,7 @@ func NewCheckGardenerClusterDeletedStep(operations storage.Operations, kcpClient step := &CheckGardenerClusterDeletedStep{ kcpClient: kcpClient, } - step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.InfrastructureManagerDependency) return step } diff --git a/internal/process/deprovisioning/check_kyma_resource_deleted_step.go b/internal/process/deprovisioning/check_kyma_resource_deleted_step.go index ad2633ba3a..73b0566615 100644 --- a/internal/process/deprovisioning/check_kyma_resource_deleted_step.go +++ b/internal/process/deprovisioning/check_kyma_resource_deleted_step.go @@ -31,7 +31,7 @@ func NewCheckKymaResourceDeletedStep(operations storage.Operations, kcpClient cl kcpClient: kcpClient, kymaResourceDeletionTimeout: kymaResourceDeletionTimeout, } - step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.LifeCycleManagerDependency) return step } diff --git a/internal/process/deprovisioning/check_runtime_removal_step.go b/internal/process/deprovisioning/check_runtime_removal_step.go index 6a3d0bf689..dc4aca0ebb 100644 --- a/internal/process/deprovisioning/check_runtime_removal_step.go +++ b/internal/process/deprovisioning/check_runtime_removal_step.go @@ -32,7 +32,7 @@ func NewCheckRuntimeRemovalStep(operations storage.Operations, instances storage instanceStorage: instances, timeout: timeout, } - step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.ProvisionerDependency) return step } diff --git a/internal/process/deprovisioning/check_runtime_resource_deletion_step.go b/internal/process/deprovisioning/check_runtime_resource_deletion_step.go index 0d6aa693ee..02a1335abc 100644 --- a/internal/process/deprovisioning/check_runtime_resource_deletion_step.go +++ b/internal/process/deprovisioning/check_runtime_resource_deletion_step.go @@ -28,7 +28,7 @@ func NewCheckRuntimeResourceDeletionStep(operations storage.Operations, kcpClien kcpClient: kcpClient, checkRuntimeResourceDeletionStepTimeout: checkRuntimeResourceDeletionStepTimeout, } - step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.InfrastructureManagerDependency) return step } diff --git a/internal/process/deprovisioning/delete_gardener_cluster.go b/internal/process/deprovisioning/delete_gardener_cluster.go index 3b15acc3b4..60d29d23e2 100644 --- a/internal/process/deprovisioning/delete_gardener_cluster.go +++ b/internal/process/deprovisioning/delete_gardener_cluster.go @@ -30,7 +30,7 @@ func NewDeleteGardenerClusterStep(operations storage.Operations, kcpClient clien kcpClient: kcpClient, instances: instances, } - step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.KEBDependency) + step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.InfrastructureManagerDependency) return step } diff --git a/internal/process/deprovisioning/delete_kyma_resource_step.go b/internal/process/deprovisioning/delete_kyma_resource_step.go index 71ac74781d..19978b7985 100644 --- a/internal/process/deprovisioning/delete_kyma_resource_step.go +++ b/internal/process/deprovisioning/delete_kyma_resource_step.go @@ -41,7 +41,7 @@ func NewDeleteKymaResourceStep(operations storage.Operations, instances storage. configProvider: configProvider, instances: instances, } - step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.LifeCycleManagerDependency) return step } diff --git a/internal/process/deprovisioning/delete_runtime_resource_step.go b/internal/process/deprovisioning/delete_runtime_resource_step.go index 25450f5693..a5036e986b 100644 --- a/internal/process/deprovisioning/delete_runtime_resource_step.go +++ b/internal/process/deprovisioning/delete_runtime_resource_step.go @@ -34,7 +34,7 @@ func NewDeleteRuntimeResourceStep(operations storage.Operations, kcpClient clien step := &DeleteRuntimeResourceStep{ kcpClient: kcpClient, } - step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.InfrastructureManagerDependency) return step } diff --git a/internal/process/deprovisioning/init.go b/internal/process/deprovisioning/init.go index 7bb75658ac..eed25b4ead 100644 --- a/internal/process/deprovisioning/init.go +++ b/internal/process/deprovisioning/init.go @@ -28,7 +28,7 @@ func NewInitStep(operations storage.Operations, instances storage.Instances, ope operationStorage: operations, instanceStorage: instances, } - step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(operations, step.Name(), kebError.KEBDependency) return step } diff --git a/internal/process/deprovisioning/release_subscription_step.go b/internal/process/deprovisioning/release_subscription_step.go index 1282e35cab..3507737598 100644 --- a/internal/process/deprovisioning/release_subscription_step.go +++ b/internal/process/deprovisioning/release_subscription_step.go @@ -31,7 +31,7 @@ func NewReleaseSubscriptionStep(os storage.Operations, instanceStorage storage.I instanceStorage: instanceStorage, accountProvider: accountProvider, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.AccountPoolDependency) return step } diff --git a/internal/process/deprovisioning/remove_instance_step.go b/internal/process/deprovisioning/remove_instance_step.go index 86eaefc482..16820fb5db 100644 --- a/internal/process/deprovisioning/remove_instance_step.go +++ b/internal/process/deprovisioning/remove_instance_step.go @@ -29,7 +29,7 @@ func NewRemoveInstanceStep(instanceStorage storage.Instances, operationStorage s instanceStorage: instanceStorage, operationStorage: operationStorage, } - step.operationManager = process.NewOperationManager(operationStorage, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(operationStorage, step.Name(), kebError.KEBDependency) return step } diff --git a/internal/process/deprovisioning/remove_runtime.go b/internal/process/deprovisioning/remove_runtime.go index e03c456e07..66cc70aced 100644 --- a/internal/process/deprovisioning/remove_runtime.go +++ b/internal/process/deprovisioning/remove_runtime.go @@ -31,7 +31,7 @@ func NewRemoveRuntimeStep(os storage.Operations, is storage.Instances, cli provi provisionerClient: cli, provisionerTimeout: provisionerTimeout, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.ProvisionerDependency) return step } diff --git a/internal/process/provisioning/create_resource_names_step.go b/internal/process/provisioning/create_resource_names_step.go index 8e036ad380..5bc0573356 100644 --- a/internal/process/provisioning/create_resource_names_step.go +++ b/internal/process/provisioning/create_resource_names_step.go @@ -20,7 +20,7 @@ type CreateResourceNamesStep struct { func NewCreateResourceNamesStep(os storage.Operations) *CreateResourceNamesStep { step := &CreateResourceNamesStep{} - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.KEBDependency) return step } diff --git a/internal/process/provisioning/create_runtime_resource_step.go b/internal/process/provisioning/create_runtime_resource_step.go index f8024ec9d7..45553924eb 100644 --- a/internal/process/provisioning/create_runtime_resource_step.go +++ b/internal/process/provisioning/create_runtime_resource_step.go @@ -61,7 +61,7 @@ func NewCreateRuntimeResourceStep(os storage.Operations, is storage.Instances, k useSmallerMachineTypes: useSmallerMachines, oidcDefaultValues: oidcDefaultValues, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.InfrastructureManagerDependency) return step } diff --git a/internal/process/provisioning/generate_runtime_id_step.go b/internal/process/provisioning/generate_runtime_id_step.go index ed700e4c2b..cefb4b0b14 100644 --- a/internal/process/provisioning/generate_runtime_id_step.go +++ b/internal/process/provisioning/generate_runtime_id_step.go @@ -25,7 +25,7 @@ func NewGenerateRuntimeIDStep(os storage.Operations, is storage.Instances) *Gene step := &GenerateRuntimeIDStep{ instanceStorage: is, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.KEBDependency) return step } diff --git a/internal/process/provisioning/get_kubeconfig_step.go b/internal/process/provisioning/get_kubeconfig_step.go index a62ecda740..55445ae7e5 100644 --- a/internal/process/provisioning/get_kubeconfig_step.go +++ b/internal/process/provisioning/get_kubeconfig_step.go @@ -28,7 +28,7 @@ func NewGetKubeconfigStep(os storage.Operations, provisionerClient: provisionerClient, kimConfig: kimConfig, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.ProvisionerDependency) return step } diff --git a/internal/process/provisioning/initialisation.go b/internal/process/provisioning/initialisation.go index 2209c1dbe9..d41a908b7b 100644 --- a/internal/process/provisioning/initialisation.go +++ b/internal/process/provisioning/initialisation.go @@ -40,7 +40,7 @@ func NewInitialisationStep(os storage.Operations, is storage.Instances, b input. inputBuilder: b, instanceStorage: is, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.KEBDependency) return step } diff --git a/internal/process/provisioning/inject_btp_operator_credentials_step.go b/internal/process/provisioning/inject_btp_operator_credentials_step.go index ef316cebe0..603f582cc6 100644 --- a/internal/process/provisioning/inject_btp_operator_credentials_step.go +++ b/internal/process/provisioning/inject_btp_operator_credentials_step.go @@ -33,7 +33,7 @@ func NewInjectBTPOperatorCredentialsStep(os storage.Operations, k8sClientProvide step := &InjectBTPOperatorCredentialsStep{ k8sClientProvider: k8sClientProvider, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.BtpManagerDependency) return step } diff --git a/internal/process/provisioning/override_kyma_modules.go b/internal/process/provisioning/override_kyma_modules.go index fafce6a8b2..b4b0bc275a 100644 --- a/internal/process/provisioning/override_kyma_modules.go +++ b/internal/process/provisioning/override_kyma_modules.go @@ -29,7 +29,7 @@ func (k *OverrideKymaModules) Name() string { func NewOverrideKymaModules(os storage.Operations) *OverrideKymaModules { step := &OverrideKymaModules{} - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.KEBDependency) return step } diff --git a/internal/process/provisioning/resolve_creds.go b/internal/process/provisioning/resolve_creds.go index a526e5a6da..a76edd6b8d 100644 --- a/internal/process/provisioning/resolve_creds.go +++ b/internal/process/provisioning/resolve_creds.go @@ -31,7 +31,7 @@ func NewResolveCredentialsStep(os storage.Operations, accountProvider hyperscale opStorage: os, accountProvider: accountProvider, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.AccountPoolDependency) return step } diff --git a/internal/process/provisioning/start_step.go b/internal/process/provisioning/start_step.go index 5bbc4d1374..4651701c14 100644 --- a/internal/process/provisioning/start_step.go +++ b/internal/process/provisioning/start_step.go @@ -3,6 +3,8 @@ package provisioning import ( "time" + kebError "github.com/kyma-project/kyma-environment-broker/internal/error" + "github.com/kyma-project/kyma-environment-broker/common/orchestration" "github.com/kyma-project/kyma-environment-broker/internal/process" "github.com/kyma-project/kyma-environment-broker/internal/storage" @@ -25,7 +27,7 @@ func NewStartStep(os storage.Operations, is storage.Instances) *StartStep { operationStorage: os, instanceStorage: is, } - step.operationManager = process.NewOperationManager(os, step.Name(), orchestration.Pending) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.KEBDependency) return step } diff --git a/internal/process/staged_manager.go b/internal/process/staged_manager.go index aae3704a6e..df6dd88233 100644 --- a/internal/process/staged_manager.go +++ b/internal/process/staged_manager.go @@ -122,7 +122,7 @@ func (m *StagedManager) Execute(operationID string) (time.Duration, error) { logOperation := m.log.WithFields(logrus.Fields{"operation": operationID, "instanceID": operation.InstanceID, "planID": operation.ProvisioningParameters.PlanID}) logOperation.Infof("Start process operation steps for GlobalAccount=%s, ", operation.ProvisioningParameters.ErsContext.GlobalAccountID) if time.Since(operation.CreatedAt) > m.operationTimeout { - timeoutErr := kebError.TimeoutError("operation has reached the time limit", kebError.NotSet) + timeoutErr := kebError.TimeoutError("operation has reached the time limit", string(kebError.KEBDependency)) operation.LastError = timeoutErr defer m.publishEventOnFail(operation, err) logOperation.Infof("operation has reached the time limit: operation was created at: %s", operation.CreatedAt) @@ -219,7 +219,7 @@ func (m *StagedManager) runStep(step Step, operation internal.Operation, logger if pErr := recover(); pErr != nil { logger.Println("panic in RunStep in staged manager: ", pErr) err = errors.New(fmt.Sprintf("%v", pErr)) - om := NewOperationManager(m.operationStorage, step.Name(), kebError.NotSet) + om := NewOperationManager(m.operationStorage, step.Name(), kebError.KEBDependency) processedOperation, _, _ = om.OperationFailed(operation, "recovered from panic", err, m.log) } }() diff --git a/internal/process/steps/gardener_cluster.go b/internal/process/steps/gardener_cluster.go index e38ea0d6fd..6169f3770d 100644 --- a/internal/process/steps/gardener_cluster.go +++ b/internal/process/steps/gardener_cluster.go @@ -28,7 +28,7 @@ func NewSyncGardenerCluster(os storage.Operations, k8sClient client.Client, kimC k8sClient: k8sClient, kimConfig: kimConfig, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.InfrastructureManagerDependency) return step } @@ -38,7 +38,7 @@ func NewCheckGardenerCluster(os storage.Operations, k8sClient client.Client, kim kimConfig: kimConfig, gardenerClusterStepTimeout: gardenerClusterStepTimeout, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.InfrastructureManagerDependency) return step } diff --git a/internal/process/steps/kyma_template.go b/internal/process/steps/kyma_template.go index 500a1a501b..484f2f0d2b 100644 --- a/internal/process/steps/kyma_template.go +++ b/internal/process/steps/kyma_template.go @@ -20,7 +20,7 @@ var _ process.Step = &InitKymaTemplate{} func NewInitKymaTemplate(os storage.Operations) *InitKymaTemplate { step := &InitKymaTemplate{} - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.KEBDependency) return step } diff --git a/internal/process/steps/lifecycle_manager_kubeconfig.go b/internal/process/steps/lifecycle_manager_kubeconfig.go index c4b545a2cf..4ec2440e75 100644 --- a/internal/process/steps/lifecycle_manager_kubeconfig.go +++ b/internal/process/steps/lifecycle_manager_kubeconfig.go @@ -31,13 +31,13 @@ type deleteKubeconfig struct { func SyncKubeconfig(os storage.Operations, k8sClient client.Client) syncKubeconfig { step := syncKubeconfig{k8sClient: k8sClient} - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.KEBDependency) return step } func DeleteKubeconfig(os storage.Operations, k8sClient client.Client) deleteKubeconfig { step := deleteKubeconfig{k8sClient: k8sClient} - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.KEBDependency) return step } diff --git a/internal/process/steps/runtime_resource.go b/internal/process/steps/runtime_resource.go index cd49b863d0..91f02100bc 100644 --- a/internal/process/steps/runtime_resource.go +++ b/internal/process/steps/runtime_resource.go @@ -23,7 +23,7 @@ func NewCheckRuntimeResourceStep(os storage.Operations, k8sClient client.Client, kimConfig: kimConfig, runtimeResourceStepTimeout: runtimeResourceStepTimeout, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.InfrastructureManagerDependency) return step } diff --git a/internal/process/update/check_step.go b/internal/process/update/check_step.go index 9d08e087a3..6338917209 100644 --- a/internal/process/update/check_step.go +++ b/internal/process/update/check_step.go @@ -29,7 +29,7 @@ func NewCheckStep(os storage.Operations, provisionerClient: provisionerClient, provisioningTimeout: provisioningTimeout, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.ProvisionerDependency) return step } diff --git a/internal/process/update/initialisation_step.go b/internal/process/update/initialisation_step.go index 4ef0047e57..32da65f4aa 100644 --- a/internal/process/update/initialisation_step.go +++ b/internal/process/update/initialisation_step.go @@ -29,7 +29,7 @@ func NewInitialisationStep(is storage.Instances, os storage.Operations, b input. instanceStorage: is, inputBuilder: b, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.KEBDependency) return step } diff --git a/internal/process/update/update_runtime_step.go b/internal/process/update/update_runtime_step.go index acd9809724..08920d8330 100644 --- a/internal/process/update/update_runtime_step.go +++ b/internal/process/update/update_runtime_step.go @@ -29,7 +29,7 @@ func NewUpdateRuntimeStep(os storage.Operations, k8sClient client.Client, delay k8sClient: k8sClient, delay: delay, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.InfrastructureManagerDependency) return step } diff --git a/internal/process/update/upgrade_shoot_step.go b/internal/process/update/upgrade_shoot_step.go index 1d5d287fd0..aa9e8f7aa6 100644 --- a/internal/process/update/upgrade_shoot_step.go +++ b/internal/process/update/upgrade_shoot_step.go @@ -41,7 +41,7 @@ func NewUpgradeShootStep( runtimeStateStorage: runtimeStorage, k8sClient: k8sClient, } - step.operationManager = process.NewOperationManager(os, step.Name(), kebError.NotSet) + step.operationManager = process.NewOperationManager(os, step.Name(), kebError.ProvisionerDependency) return step }