From e00024f136996305999c0440ae9b48861828e160 Mon Sep 17 00:00:00 2001
From: Marco Nenciarini <marco.nenciarini@enterprisedb.com>
Date: Wed, 16 Apr 2025 11:45:52 +0200
Subject: [PATCH] feat: support snapshot recovery job (#258)

Signed-off-by: Marco Nenciarini <marco.nenciarini@enterprisedb.com>
---
 internal/cnpgi/operator/lifecycle.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/internal/cnpgi/operator/lifecycle.go b/internal/cnpgi/operator/lifecycle.go
index a6e95d0..2e13325 100644
--- a/internal/cnpgi/operator/lifecycle.go
+++ b/internal/cnpgi/operator/lifecycle.go
@@ -153,7 +153,9 @@ func reconcileJob(
 		WithValues("jobName", job.Name)
 	contextLogger.Debug("starting job reconciliation")
 
-	if getCNPGJobRole(&job) != "full-recovery" {
+	jobRole := getCNPGJobRole(&job)
+	if jobRole != "full-recovery" &&
+		jobRole != "snapshot-recovery" {
 		contextLogger.Debug("job is not a recovery job, skipping")
 		return nil, nil
 	}
@@ -163,7 +165,7 @@ func reconcileJob(
 	if err := reconcilePodSpec(
 		cluster,
 		&mutatedJob.Spec.Template.Spec,
-		"full-recovery",
+		jobRole,
 		corev1.Container{
 			Args: []string{"restore"},
 		},