cmd/sync: improve sync log (juicedata#5668)

zhijian-pro · web-flow · commit 7d118a471398 · 2025-02-18T14:55:00.000+08:00
diff --git a/pkg/sync/cluster.go b/pkg/sync/cluster.go
@@ -371,6 +371,7 @@ func fetchJobs(tasks chan<- object.Object, config *Config) {
 		}
 		logger.Debugf("got %d jobs", len(jobs))
 		if len(jobs) == 0 {
+			logger.Infof("no more jobs")
 			break
 		}
 		for _, obj := range jobs {
diff --git a/pkg/sync/sync.go b/pkg/sync/sync.go
@@ -1537,7 +1537,7 @@ func Sync(src, dst object.ObjectStorage, config *Config) error {
 			logger.Info(msg)
 		} else {
 			sendStats(config.Manager)
-			logger.Debugf("This worker process has already completed its task")
+			logger.Infof("This worker process has already completed its task")
 		}
 		if failed != nil {
 			if n := failed.Current(); n > 0 || total > handled.Current() {

Original file line number	Diff line number	Diff line change
`@@ -371,6 +371,7 @@ func fetchJobs(tasks chan<- object.Object, config *Config) {`
`371`	`371`	`}`
`372`	`372`	`logger.Debugf("got %d jobs", len(jobs))`
`373`	`373`	`if len(jobs) == 0 {`
	`374`	`+ logger.Infof("no more jobs")`
`374`	`375`	`break`
`375`	`376`	`}`
`376`	`377`	`for _, obj := range jobs {`
Original file line number	Diff line number	Diff line change
`@@ -1537,7 +1537,7 @@ func Sync(src, dst object.ObjectStorage, config *Config) error {`
`1537`	`1537`	`logger.Info(msg)`
`1538`	`1538`	`} else {`
`1539`	`1539`	`sendStats(config.Manager)`
`1540`		`- logger.Debugf("This worker process has already completed its task")`
	`1540`	`+ logger.Infof("This worker process has already completed its task")`
`1541`	`1541`	`}`
`1542`	`1542`	`if failed != nil {`
`1543`	`1543`	`if n := failed.Current(); n > 0 \|\| total > handled.Current() {`