We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c32ddf1 commit e00024fCopy full SHA for e00024f
internal/cnpgi/operator/lifecycle.go
@@ -153,7 +153,9 @@ func reconcileJob(
153
WithValues("jobName", job.Name)
154
contextLogger.Debug("starting job reconciliation")
155
156
- if getCNPGJobRole(&job) != "full-recovery" {
+ jobRole := getCNPGJobRole(&job)
157
+ if jobRole != "full-recovery" &&
158
+ jobRole != "snapshot-recovery" {
159
contextLogger.Debug("job is not a recovery job, skipping")
160
return nil, nil
161
}
@@ -163,7 +165,7 @@ func reconcileJob(
163
165
if err := reconcilePodSpec(
164
166
cluster,
167
&mutatedJob.Spec.Template.Spec,
- "full-recovery",
168
+ jobRole,
169
corev1.Container{
170
Args: []string{"restore"},
171
},
0 commit comments