Restyled by gofmt

iterative · Jan 7, 2022 · 71129b7 · 71129b7
1 parent 71b9f77
commit 71129b7
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 11 deletions.
diff --git a/task/common/machine/storage.go b/task/common/machine/storage.go
@@ -7,7 +7,6 @@ import (
 	"io"
 	"path/filepath"
 	"strings"
-	"log"
 
 	_ "github.com/rclone/rclone/backend/azureblob"
 	_ "github.com/rclone/rclone/backend/googlecloudstorage"
@@ -21,9 +20,9 @@ import (
 )
 
 type StatusReport struct {
-  Result string
-  Status string
-  Code string
+	Result string
+	Status string
+	Code   string
 }
 
 func Reports(ctx context.Context, remote, prefix string) ([]string, error) {

diff --git a/task/common/values.go b/task/common/values.go
@@ -26,9 +26,9 @@ type Status map[StatusCode]int
 type StatusCode string
 
 const (
-	StatusCodeActive StatusCode = "running"
+	StatusCodeActive    StatusCode = "running"
 	StatusCodeSucceeded StatusCode = "succeeded"
-	StatusCodeFailed StatusCode = "failed"
+	StatusCodeFailed    StatusCode = "failed"
 )
 
 type Size struct {

diff --git a/task/k8s/resources/resource_job.go b/task/k8s/resources/resource_job.go
@@ -265,9 +265,9 @@ func (j *Job) Read(ctx context.Context) error {
 		})
 	}
 	j.Attributes.Status = common.Status{
-		common.StatusCodeActive:       int(job.Status.Active),
-		common.StatusCodeSucceeded:       int(job.Status.Succeeded),
-		common.StatusCodeFailed:       int(job.Status.Failed),
+		common.StatusCodeActive:    int(job.Status.Active),
+		common.StatusCodeSucceeded: int(job.Status.Succeeded),
+		common.StatusCodeFailed:    int(job.Status.Failed),
 	}
 	j.Resource = job
 	return nil

diff --git a/task/task_test.go b/task/task_test.go
@@ -136,7 +136,7 @@ func TestTask(t *testing.T) {
 
 				for assert.Nil(t, newTask.Read(ctx)) {
 					status, err := newTask.Status(ctx)
-					require.Nil(err)
+					require.Nil(t, err)
 					if status[common.StatusCodeActive] > 0 {
 						break
 					}
@@ -147,7 +147,7 @@ func TestTask(t *testing.T) {
 
 				for assert.Nil(t, newTask.Read(ctx)) {
 					status, err := newTask.Status(ctx)
-					require.Nil(err)
+					require.Nil(t, err)
 					if status[common.StatusCodeActive] == 0 {
 						break
 					}