diff --git a/pkg/globalmanager/controllers/featureextraction/featureextractionservice.go b/pkg/globalmanager/controllers/featureextraction/featureextractionservice.go index f646066c0..fe721334e 100644 --- a/pkg/globalmanager/controllers/featureextraction/featureextractionservice.go +++ b/pkg/globalmanager/controllers/featureextraction/featureextractionservice.go @@ -150,7 +150,7 @@ func (c *Controller) addDeployment(obj interface{}) { c.enqueueByDeployment(deployment) } -//deleteDeployment enqueues the FeatureExtractionService obj When a deleteDeployment is deleted +// deleteDeployment enqueues the FeatureExtractionService obj When a deleteDeployment is deleted func (c *Controller) deleteDeployment(obj interface{}) { deployment, ok := obj.(*appsv1.Deployment) @@ -513,7 +513,7 @@ func (c *Controller) createFeatureExtractionWorker(service *sednav1.FeatureExtra } // Create FE deployment AND related pods (as part of the deployment creation) - _, err = runtime.CreateDeploymentWithTemplate(c.kubeClient, service, &service.Spec.DeploymentSpec, &workerParam, FEPort) + _, err = runtime.CreateDeploymentWithTemplate(c.kubeClient, service, &service.Spec.DeploymentSpec, &workerParam) if err != nil { return fmt.Errorf("failed to create feature extraction deployment: %w", err) } diff --git a/pkg/globalmanager/controllers/objectsearch/objectsearchservice.go b/pkg/globalmanager/controllers/objectsearch/objectsearchservice.go index d33c0135f..0da2cad4b 100644 --- a/pkg/globalmanager/controllers/objectsearch/objectsearchservice.go +++ b/pkg/globalmanager/controllers/objectsearch/objectsearchservice.go @@ -501,7 +501,7 @@ func (c *Controller) createWorkers(service *sednav1.ObjectSearchService) (active // create reid worker deployment var reidWorkerParam runtime.WorkerParam reidWorkerParam.WorkerType = objectSearchReidWorker - _, err = runtime.CreateDeploymentWithTemplate(c.kubeClient, service, &service.Spec.ReidWorkers.DeploymentSpec, &reidWorkerParam, reidServicePort) + _, err = runtime.CreateDeploymentWithTemplate(c.kubeClient, service, &service.Spec.ReidWorkers.DeploymentSpec, &reidWorkerParam) if err != nil { return activePods, activeDeployments, fmt.Errorf("failed to create reid worker deployment: %w", err) } @@ -528,7 +528,7 @@ func (c *Controller) createWorkers(service *sednav1.ObjectSearchService) (active "SERVICE_NAME": service.Name, "WORKER_NAME": "userworker-" + utilrand.String(5), } - _, err = runtime.CreateDeploymentWithTemplate(c.kubeClient, service, userWorkerDeployment, &userWorkerParam, userWorkerPort) + _, err = runtime.CreateDeploymentWithTemplate(c.kubeClient, service, userWorkerDeployment, &userWorkerParam) if err != nil { return activePods, activeDeployments, fmt.Errorf("failed to create user worker: %w", err)