Compare commits

...

2 Commits

Author SHA1 Message Date
Niccolò Fei
f3fcbe14ee test: remove redundant primary/standby picking logic
If pod-1 is not the primary we'd fail anyway because a timeline
bump would make all assertions about the walLogDir fail.
Also there's no reason why there should have been a switchover,
so we should not hide a failure if that happens.

Signed-off-by: Niccolò Fei <niccolo.fei@enterprisedb.com>
2026-06-23 18:45:12 +02:00
Niccolò Fei
c5003200ce chore: bump aws-cli to 2.35.11
Signed-off-by: Niccolò Fei <niccolo.fei@enterprisedb.com>
2026-06-23 18:38:10 +02:00
2 changed files with 3 additions and 6 deletions

View File

@ -121,7 +121,7 @@ func newS3ClientDeployment(namespace string) *appsv1.Deployment {
{ {
Name: s3ClientName, Name: s3ClientName,
// renovate: datasource=docker depName=amazon/aws-cli versioning=docker // renovate: datasource=docker depName=amazon/aws-cli versioning=docker
Image: "docker.io/amazon/aws-cli:2.35.4", Image: "docker.io/amazon/aws-cli:2.35.11",
Command: []string{"sleep", "infinity"}, Command: []string{"sleep", "infinity"},
Env: []corev1.EnvVar{ Env: []corev1.EnvVar{
{ {

View File

@ -59,7 +59,7 @@ const (
managerExecutable = "/controller/manager" managerExecutable = "/controller/manager"
// postgresContainer is the container we exec into on instance pods. // postgresContainer is the container we exec into on instance pods.
postgresContainer = "postgres" postgresContainer = "postgres"
// walLogDir is the wals sub-directory (timeline + log id) the forged segments // walLogDir is the WALs subdirectory (timeline + log id) the forged segments
// live under; a freshly bootstrapped, idle cluster stays within it. // live under; a freshly bootstrapped, idle cluster stays within it.
walLogDir = "0000000100000000" walLogDir = "0000000100000000"
// bucket is the destination bucket of the minio ObjectStore. // bucket is the destination bucket of the minio ObjectStore.
@ -105,7 +105,7 @@ func execInPod(
// This test drives the plugin's parallel WAL restore directly: it invokes the // This test drives the plugin's parallel WAL restore directly: it invokes the
// instance-manager wal-restore command on the standby (which delegates to the // instance-manager wal-restore command on the standby (which delegates to the
// plugin) and asserts the prefetch/spool/end-of-wal-stream state machine with // plugin) and asserts the prefetch/spool/end-of-wal-stream state machine with
// maxParallel = 3. To control the archive deterministically it forges WAL // maxParallel = 3. To control the archive deterministically, it forges WAL
// segments on the object store by copying a real archived segment under new // segments on the object store by copying a real archived segment under new
// names. // names.
var _ = Describe("Parallel WAL restore", func() { var _ = Describe("Parallel WAL restore", func() {
@ -166,9 +166,6 @@ var _ = Describe("Parallel WAL restore", func() {
primary := cluster.Status.CurrentPrimary primary := cluster.Status.CurrentPrimary
Expect(primary).NotTo(BeEmpty()) Expect(primary).NotTo(BeEmpty())
standby := clusterName + "-2" standby := clusterName + "-2"
if primary == standby {
standby = clusterName + "-1"
}
var s3ClientPods corev1.PodList var s3ClientPods corev1.PodList
Expect(cl.List(ctx, &s3ClientPods, Expect(cl.List(ctx, &s3ClientPods,