diff --git a/tests/rptest/tests/datalake/delayed_translation_test.py b/tests/rptest/tests/datalake/delayed_translation_test.py index 5c7fb4ec5c9d9..60b750b935f28 100644 --- a/tests/rptest/tests/datalake/delayed_translation_test.py +++ b/tests/rptest/tests/datalake/delayed_translation_test.py @@ -54,6 +54,7 @@ def __init__(self, test_ctx, *args, **kwargs): cloud_storage_max_connections=5, cloud_storage_enable_remote_read=True, cloud_storage_enable_remote_write=True, + fast_uploads=True, ), extra_rp_conf={"iceberg_enabled": False}, schema_registry_config=SchemaRegistryConfig(), @@ -95,13 +96,14 @@ def _query_minmax(self, query_engine: QueryEngineBase): def produce_until_result(self, *args, **kwargs): try: + count = 50000 if self.redpanda.dedicated_nodes else 10000 self._connect.start_stream( name="ducky_stream", config=counter_stream_config( self.redpanda, self.TOPIC_NAME, self.SCHEMA_NAME, - {"weight": "range(0, 10000)"}, + {"weight": f"range(0, {count})"}, 0, ), )