parallelism

cmd/lakectl/cmd/fs_upload.go

@@ -2,12 +2,10 @@ package cmd
 
 import (
 	"context"
-	"fmt"
 	"os"
 	"os/signal"
 	"path/filepath"
 	"strings"
-	"time"
 
 	"github.com/spf13/cobra"
 	"github.com/treeverse/lakefs/pkg/api/apigen"
@@ -23,7 +21,6 @@ var fsUploadCmd = &cobra.Command{
 	Args:              cobra.ExactArgs(1),
 	ValidArgsFunction: ValidArgsRepository,
 	Run: func(cmd *cobra.Command, args []string) {
-		start := time.Now()
 		client := getClient()
 		pathURI, _ := getSyncArgs(args, true, false)
 		syncFlags := getSyncFlags(cmd, client)
@@ -85,9 +82,6 @@ var fsUploadCmd = &cobra.Command{
 			Operation: "Upload",
 			Tasks:     s.Summary(),
 		})
-		finish := time.Since(start)
-		fmt.Printf("Execution time: %s\n", finish)
-
 	},
 }
 

cmd/lakectl/cmd/root.go

@@ -74,7 +74,7 @@ type Configuration struct {
 	} `mapstructure:"server"`
 	Options struct {
 		Parallelism int `mapstructure:"parallelism"`
-	} `mapstructure:"Job"`
+	} `mapstructure:"options"`
 	Metastore struct {
 		Type lakefsconfig.OnlyString `mapstructure:"type"`
 		Hive struct {
@@ -578,7 +578,7 @@ func initConfig() {
 	viper.SetDefault("server.retries.min_wait_interval", defaultMinRetryInterval)
 	viper.SetDefault("experimental.local.posix_permissions.enabled", false)
 	viper.SetDefault("local.skip_non_regular_files", false)
-	viper.SetDefault("job.parallelism", defaultParallelismConfig)
+	viper.SetDefault("options.parallelism", defaultParallelismConfig)
 
 	cfgErr = viper.ReadInConfig()
 }