minor modification

kubernetes · Feb 5, 2021 · f17bb8f · f17bb8f
1 parent 5f31ac0
commit f17bb8f
Showing 1 changed file with 2 additions and 13 deletions.
diff --git a/util-images/network/netperfbenchmark/pkg/worker/worker.go b/util-images/network/netperfbenchmark/pkg/worker/worker.go
@@ -223,9 +223,9 @@ func (w *Worker) getStartTimestamp() int64 {
 }
 
 func (w *Worker) updateStatus(status map[string]interface{}) error {
-	resource, err := w.getResource()
+	resource, err := w.resourceInterface.Get(context.TODO(), w.work.resourceName, metav1.GetOptions{})
 	if err != nil {
-		return fmt.Errorf("Updating status failed: %v,", err)
+		return fmt.Errorf("updating status failed: %v", err)
 	}
 	resourceContent := resource.UnstructuredContent()
 	resourceContent["status"] = status
@@ -240,17 +240,6 @@ func (w *Worker) updateStatus(status map[string]interface{}) error {
 	return nil
 }
 
-func (w *Worker) getResource() (*unstructured.Unstructured, error) {
-	resourceContent, err := w.resourceInterface.Get(context.TODO(), w.work.resourceName, metav1.GetOptions{})
-	if err != nil {
-		err := fmt.Errorf("error getting custom resource: %v", err)
-		klog.Error(err)
-		return nil, err
-	}
-	return resourceContent, nil
-
-}
-
 func (w *Worker) handleError(err error) {
 	klog.Error(err)
 	if err := w.updateStatus(makeErrorStatus(err)); err != nil {