chore(restore): add more logs for restore request (#8050) (#8975)

dgraph-io · Nov 27, 2023 · e20d690 · e20d690
1 parent a2ed132
commit e20d690
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 2 deletions.
diff --git a/graphql/admin/restore.go b/graphql/admin/restore.go
@@ -55,6 +55,8 @@ func resolveRestore(ctx context.Context, m schema.Mutation) (*resolve.Resolved,
 	if err != nil {
 		return resolve.EmptyResult(m, err), false
 	}
+	glog.Infof("Got restore request, location: %v, backupId: %v, backupNum: %v, incrementalFrom: %d, isPartial: %v",
+		input.Location, input.BackupId, input.BackupNum, input.IncrementalFrom, input.IsPartial)
 
 	req := pb.RestoreRequest{
 		Location:          input.Location,

diff --git a/worker/online_restore.go b/worker/online_restore.go
@@ -204,9 +204,10 @@ func tryRestoreProposal(ctx context.Context, req *pb.RestoreRequest) error {
 	for i := 0; i < 10; i++ {
 		err = proposeRestoreOrSend(ctx, req)
 		if err == nil {
+			glog.Info("proposeRestoreOrSend done.")
 			return nil
 		}
-
+		glog.Errorf("Got error while proposeRestoreOrSend: %v, retrying!", err)
 		if retriableRestoreError(err) {
 			time.Sleep(time.Second)
 			continue
@@ -229,6 +230,7 @@ func (w *grpcWorker) Restore(ctx context.Context, req *pb.RestoreRequest) (*pb.S
 		return nil, errors.Wrapf(err, "cannot wait for restore ts %d", req.RestoreTs)
 	}
 
+	glog.Infof("Proposing restore request")
 	err := groups().Node.proposeAndWait(ctx, &pb.Proposal{Restore: req})
 	if err != nil {
 		return &emptyRes, errors.Wrapf(err, errRestoreProposal)
@@ -415,12 +417,14 @@ func handleRestoreProposal(ctx context.Context, req *pb.RestoreRequest, pidx uin
 	go func(idx uint64) {
 		n := groups().Node
 		if !n.AmLeader() {
+			glog.Infof("I am not leader, not proposing snapshot")
 			return
 		}
 		if err := n.Applied.WaitForMark(context.Background(), idx); err != nil {
 			glog.Errorf("Error waiting for mark for index %d: %+v", idx, err)
 			return
 		}
+		glog.Infof("I am the leader, proposing snapshot after restore")
 		if err := n.proposeSnapshot(); err != nil {
 			glog.Errorf("cannot propose snapshot after processing restore proposal %+v", err)
 		}

diff --git a/worker/restore_map.go b/worker/restore_map.go
@@ -799,8 +799,8 @@ func RunMapper(req *pb.RestoreRequest, mapDir string) (*mapResult, error) {
 				}
 				maxBannedNs = x.Max(maxBannedNs, ns)
 			}
-			glog.Infof("[MAP] Processed manifest %d\n", manifest.BackupNum)
 		}
+		glog.Infof("[MAP] Processed manifest num: %v", manifest.BackupNum)
 	} // done with all the manifests.
 
 	glog.Infof("Histogram of map input sizes:\n%s\n", mapper.szHist)