diff --git a/worker/online_restore_ee.go b/worker/online_restore_ee.go
index a51d07ea0a0..7cafd4e09d0 100644
--- a/worker/online_restore_ee.go
+++ b/worker/online_restore_ee.go
@@ -83,7 +83,7 @@ func ProcessRestoreRequest(ctx context.Context, req *pb.RestoreRequest) error {
 }
 
 func proposeRestoreOrSend(ctx context.Context, req *pb.RestoreRequest) error {
-	if groups().ServesGroup(req.GetGroupId()) {
+	if groups().ServesGroup(req.GetGroupId()) && groups().Node.AmLeader() {
 		_, err := (&grpcWorker{}).Restore(ctx, req)
 		return err
 	}