fixup! Precreate DR kafka volume

scality · Aug 16, 2024 · 619423d · 619423d
1 parent bab953a
commit 619423d
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/tests/ctst/steps/pra.ts b/tests/ctst/steps/pra.ts
@@ -49,14 +49,16 @@ interface DrState {
 }
 
 async function installPRA(world: Zenko, sinkS3Endpoint = 'http://s3.zenko.local') {
+    const kafkaExternalIpOption = !!world.parameters.KafkaExternalIps ?
+        { kafkaExternalIps: world.parameters.KafkaExternalIps } :
+        { kafkaExternalIpsDiscovery: true };
+
     return world.zenkoDrCtl?.install({
         sourceZenkoDrInstance: 'end2end-source',
         sinkZenkoDrInstance: 'end2end-pra-sink',
         kafkaPersistenceSize: '1Gi',
         kafkaPersistenceStorageClassName: '-',
         kafkaPersistenceSelector: 'app=kafka-dr-sink',
-        kafkaExternalIps: world.parameters.KafkaExternalIps,
-        kafkaExternalIpsDiscovery: !world.parameters.KafkaExternalIps,
         locations: 'e2e-cold', // comma-separated list
         s3Bucket: 'dump-db',
         sinkZenkoInstance: 'end2end-pra',
@@ -65,6 +67,7 @@ async function installPRA(world: Zenko, sinkS3Endpoint = 'http://s3.zenko.local'
         sourceZenkoNamespace: 'default',
         sourceS3Endpoint: 'http://s3.zenko.local',
         sinkS3Endpoint,
+        ...kafkaExternalIpOption,
     });
 }