K8SPG-781 add original error (#1207)

nmarukovich · hors · web-flow · commit bf2b043bac10 · 2025-07-23T16:57:37.000+03:00
* K8SPG-781 add original error

* K8SPG-781 add original error

* K8SPG-781 add original error

* fix PR comments

---------

Co-authored-by: Viacheslav Sarzhan &lt;slava.sarzhan@percona.com&gt;
diff --git a/percona/watcher/wal.go b/percona/watcher/wal.go
@@ -167,7 +167,7 @@ func GetLatestCommitTimestamp(ctx context.Context, cli client.Client, execCli *c
 
 	primary, err := perconaPG.GetPrimaryPod(ctx, cli, cr)
 	if err != nil {
-		return nil, PrimaryPodNotFound
+		return nil, errors.Wrap(PrimaryPodNotFound, err.Error())
 	}
 
 	log.V(1).Info("Getting latest commit timestamp from primary pod", "pod", primary.Name)
@@ -203,7 +203,7 @@ func GetLatestCommitTimestamp(ctx context.Context, cli client.Client, execCli *c
 func getBackupStartTimestamp(ctx context.Context, cli client.Client, cr *pgv2.PerconaPGCluster, backup *pgv2.PerconaPGBackup) (time.Time, error) {
 	primary, err := perconaPG.GetPrimaryPod(ctx, cli, cr)
 	if err != nil {
-		return time.Time{}, PrimaryPodNotFound
+		return time.Time{}, errors.Wrap(PrimaryPodNotFound, err.Error())
 	}
 
 	pgbackrestInfo, err := pgbackrest.GetInfo(ctx, primary, backup.Spec.RepoName)

Original file line number	Diff line number	Diff line change
`@@ -167,7 +167,7 @@ func GetLatestCommitTimestamp(ctx context.Context, cli client.Client, execCli *c`
`167`	`167`
`168`	`168`	`primary, err := perconaPG.GetPrimaryPod(ctx, cli, cr)`
`169`	`169`	`if err != nil {`
`170`		`- return nil, PrimaryPodNotFound`
	`170`	`+ return nil, errors.Wrap(PrimaryPodNotFound, err.Error())`
`171`	`171`	`}`
`172`	`172`
`173`	`173`	`log.V(1).Info("Getting latest commit timestamp from primary pod", "pod", primary.Name)`
`@@ -203,7 +203,7 @@ func GetLatestCommitTimestamp(ctx context.Context, cli client.Client, execCli *c`
`203`	`203`	`func getBackupStartTimestamp(ctx context.Context, cli client.Client, cr pgv2.PerconaPGCluster, backup pgv2.PerconaPGBackup) (time.Time, error) {`
`204`	`204`	`primary, err := perconaPG.GetPrimaryPod(ctx, cli, cr)`
`205`	`205`	`if err != nil {`
`206`		`- return time.Time{}, PrimaryPodNotFound`
	`206`	`+ return time.Time{}, errors.Wrap(PrimaryPodNotFound, err.Error())`
`207`	`207`	`}`
`208`	`208`
`209`	`209`	`pgbackrestInfo, err := pgbackrest.GetInfo(ctx, primary, backup.Spec.RepoName)`