Reformatting (#1125)

Author: Zou Nengren

cli/cmd/cluster.go

@@ -533,7 +533,7 @@ func printInfoPricing(infoResponse *schema.InfoResponse, clusterConfig clusterco
 		{Title: "cost per hour"},
 	}
 
-	rows := [][]interface{}{}
+	var rows [][]interface{}
 	rows = append(rows, []interface{}{"1 eks cluster", s.DollarsMaxPrecision(eksPrice)})
 	rows = append(rows, []interface{}{fmt.Sprintf("%d %s for your apis", numAPIInstances, s.PluralS("instance", numAPIInstances)), s.DollarsAndTenthsOfCents(totalAPIInstancePrice) + " total"})
 	rows = append(rows, []interface{}{fmt.Sprintf("%d %dgb ebs %s for your apis", numAPIInstances, clusterConfig.InstanceVolumeSize, s.PluralS("volume", numAPIInstances)), s.DollarsAndTenthsOfCents(apiEBSPrice*float64(numAPIInstances)) + " total"})
@@ -587,7 +587,7 @@ func printInfoNodes(infoResponse *schema.InfoResponse) {
 		{Title: "GPU (free / total)", Hidden: !doesClusterHaveGPUs},
 	}
 
-	rows := [][]interface{}{}
+	var rows [][]interface{}
 	for _, nodeInfo := range infoResponse.NodeInfos {
 		lifecycle := "on-demand"
 		if nodeInfo.IsSpot {
@@ -675,7 +675,7 @@ func refreshCachedClusterConfig(awsCreds AWSCredentials, accessConfig *clusterco
 
 	mountedConfigPath := mountedClusterConfigPath(*accessConfig.ClusterName, *accessConfig.Region)
 
-	fmt.Println("syncing cluster configuration ..." + "\n")
+	fmt.Print("syncing cluster configuration ...\n\n")
 	out, exitCode, err := runManagerAccessCommand("/root/refresh.sh "+mountedConfigPath, *accessConfig, awsCreds, _flagClusterEnv)
 	if err != nil {
 		exit.Error(err)

cli/cmd/root.go

@@ -30,16 +30,18 @@ import (
 	"github.com/spf13/cobra"
 )
 
-var _cmdStr string
+var (
+	_cmdStr string
 
-var _configFileExts = []string{"yaml", "yml"}
+	_configFileExts = []string{"yaml", "yml"}
 
-var _localDir string
-var _cliConfigPath string
-var _clientIDPath string
-var _emailPath string
-var _debugPath string
-var _cwd string
+	_localDir      string
+	_cliConfigPath string
+	_clientIDPath  string
+	_emailPath     string
+	_debugPath     string
+	_cwd           string
+)
 
 type commandType int
 

cli/local/docker_spec.go

@@ -144,7 +144,7 @@ func deployPythonContainer(api *spec.API, awsClient *aws.Client) error {
 			{
 				Type:   mount.TypeBind,
 				Source: filepath.Join(_localWorkspaceDir, filepath.Dir(api.Key)),
-				Target: "/mnt/workspace",
+				Target: _workspaceDir,
 			},
 		},
 	}
@@ -207,7 +207,7 @@ func deployONNXContainer(api *spec.API, awsClient *aws.Client) error {
 		{
 			Type:   mount.TypeBind,
 			Source: filepath.Join(_localWorkspaceDir, filepath.Dir(api.Key)),
-			Target: "/mnt/workspace",
+			Target: _workspaceDir,
 		},
 	}
 	for _, modelCache := range api.LocalModelCaches {
@@ -347,7 +347,7 @@ func deployTensorFlowContainers(api *spec.API, awsClient *aws.Client) error {
 			{
 				Type:   mount.TypeBind,
 				Source: filepath.Join(_localWorkspaceDir, filepath.Dir(api.Key)),
-				Target: "/mnt/workspace",
+				Target: _workspaceDir,
 			},
 		}, mounts...),
 	}

cli/local/get.go

@@ -43,8 +43,8 @@ func GetAPIs() (schema.GetAPIsResponse, error) {
 		return schema.GetAPIsResponse{}, err
 	}
 
-	statusList := []status.Status{}
-	metricsList := []metrics.Metrics{}
+	var statusList []status.Status
+	var metricsList []metrics.Metrics
 	for _, apiSpec := range apiSpecList {
 		apiStatus, err := GetAPIStatus(&apiSpec)
 		if err != nil {

cli/local/logs.go

@@ -40,7 +40,7 @@ func StreamLogs(apiName string) error {
 		return ErrorAPIContainersNotFound(apiName)
 	}
 
-	containerIDs := []string{}
+	var containerIDs []string
 	for _, container := range containers {
 		containerIDs = append(containerIDs, container.ID)
 	}

cli/local/model_cache.go

@@ -136,7 +136,7 @@ func CacheModel(modelPath string, awsClient *aws.Client) (*spec.LocalModelCache,
 }
 
 func DeleteCachedModels(apiName string, modelsToDelete []string) error {
-	errList := []error{}
+	var errList []error
 	modelsInUse := strset.New()
 	apiSpecList, err := ListAPISpecs()
 	errList = append(errList, err)