From f17bb8f5508eac8a22db1c5304dd080cd461c164 Mon Sep 17 00:00:00 2001 From: Vivek Thrivikraman Date: Sat, 6 Feb 2021 00:32:41 +0530 Subject: [PATCH] minor modification --- .../network/netperfbenchmark/pkg/worker/worker.go | 15 ++------------- 1 file changed, 2 insertions(+), 13 deletions(-) diff --git a/util-images/network/netperfbenchmark/pkg/worker/worker.go b/util-images/network/netperfbenchmark/pkg/worker/worker.go index e09d7bb3e0..eaa8474e09 100644 --- 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 {