From ccb349059f391a1f64d80addf72750ec4b166d1b Mon Sep 17 00:00:00 2001
From: GheisMohammadi <Gheis.Mohammadi@gmail.com>
Date: Wed, 15 Oct 2025 21:16:31 +0800
Subject: [PATCH] Add retry mechanism for leader nodes in staged stream sync
 downloader

---
 api/service/synchronize/stagedstreamsync/downloader.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/api/service/synchronize/stagedstreamsync/downloader.go b/api/service/synchronize/stagedstreamsync/downloader.go
index aba23d61d5..68f339c775 100644
--- a/api/service/synchronize/stagedstreamsync/downloader.go
+++ b/api/service/synchronize/stagedstreamsync/downloader.go
@@ -320,6 +320,11 @@ func (d *Downloader) handleDownload(trigger func()) {
 
 	// if it's leader, skip syncing for now
 	if d.stagedSyncInstance.consensus != nil && d.stagedSyncInstance.consensus.IsLeader() {
+		// Retry sync after 1 seconds
+		go func() {
+			time.Sleep(1 * time.Second)
+			trigger()
+		}()
 		return
 	}