From 7ea2c24c5d0b6ea49093e9aa081aa704f78216fe Mon Sep 17 00:00:00 2001
From: chrislu <chris.lu@gmail.com>
Date: Mon, 22 Aug 2022 11:25:40 -0700
Subject: [PATCH] metadata processing use retry instead of retryForEver

---
 weed/command/filer_sync_jobs.go | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/weed/command/filer_sync_jobs.go b/weed/command/filer_sync_jobs.go
index 3e9bb9f37..50428a3ad 100644
--- a/weed/command/filer_sync_jobs.go
+++ b/weed/command/filer_sync_jobs.go
@@ -41,12 +41,11 @@ func (t *MetadataProcessor) AddSyncJob(resp *filer_pb.SubscribeMetadataResponse)
 	t.activeJobs[resp.TsNs] = resp
 	go func() {
 
-		util.RetryForever("metadata processor", func() error {
+		if err := util.Retry("metadata processor", func() error {
 			return t.fn(resp)
-		}, func(err error) bool {
+		}); err != nil {
 			glog.Errorf("process %v: %v", resp, err)
-			return true
-		})
+		}
 
 		t.activeJobsLock.Lock()
 		defer t.activeJobsLock.Unlock()