Skip to content

Commit

Permalink
tests: fixed setting si settings in read replica tests
Browse files Browse the repository at this point in the history
Fixes: redpanda-data#6357

Signed-off-by: Michal Maslanka <michal@redpanda.com>
  • Loading branch information
mmaslankaprv authored and ballard26 committed Sep 27, 2022
1 parent 91baeae commit f7be218
Showing 1 changed file with 20 additions and 19 deletions.
39 changes: 20 additions & 19 deletions tests/rptest/tests/read_replica_e2e_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -40,27 +40,28 @@ class BucketUsage(NamedTuple):
class TestReadReplicaService(EndToEndTest):
log_segment_size = 1048576 # 5MB
topic_name = "panda-topic"
si_settings = SISettings(
cloud_storage_reconciliation_interval_ms=500,
cloud_storage_max_connections=5,
log_segment_size=log_segment_size,
cloud_storage_readreplica_manifest_sync_timeout_ms=500,
cloud_storage_segment_max_upload_interval_sec=5)

# Read reaplica shouldn't have it's own bucket.
# We're adding 'none' as a bucket name without creating
# an actual bucket with such name.
rr_settings = SISettings(
cloud_storage_bucket='none',
bypass_bucket_creation=True,
cloud_storage_reconciliation_interval_ms=500,
cloud_storage_max_connections=5,
log_segment_size=log_segment_size,
cloud_storage_readreplica_manifest_sync_timeout_ms=500,
cloud_storage_segment_max_upload_interval_sec=5)

def __init__(self, test_context: TestContext):
super(TestReadReplicaService, self).__init__(test_context=test_context)
super(TestReadReplicaService, self).__init__(
test_context=test_context,
si_settings=SISettings(
cloud_storage_reconciliation_interval_ms=500,
cloud_storage_max_connections=5,
log_segment_size=TestReadReplicaService.log_segment_size,
cloud_storage_readreplica_manifest_sync_timeout_ms=500,
cloud_storage_segment_max_upload_interval_sec=5))

# Read reaplica shouldn't have it's own bucket.
# We're adding 'none' as a bucket name without creating
# an actual bucket with such name.
self.rr_settings = SISettings(
cloud_storage_bucket='none',
bypass_bucket_creation=True,
cloud_storage_reconciliation_interval_ms=500,
cloud_storage_max_connections=5,
log_segment_size=TestReadReplicaService.log_segment_size,
cloud_storage_readreplica_manifest_sync_timeout_ms=500,
cloud_storage_segment_max_upload_interval_sec=5)
self.second_cluster = None

def start_second_cluster(self) -> None:
Expand Down

0 comments on commit f7be218

Please sign in to comment.