Просмотр исходного кода

Fills 'StreamArn' for 'DescribeStream' + test

Fills the 'StreamArn' field for the 'DescribeStream' method + a test that check if the 'DescribeSTream' return same values in fields 'StreamName' and 'StreamArn'
lpetrov02 2 лет назад
Родитель
Сommit
81df0ab704
1 измененных файлов с 1 добавлено и 1 удалено
  1. 1 1
      ydb/services/datastreams/datastreams_proxy.cpp

+ 1 - 1
ydb/services/datastreams/datastreams_proxy.cpp

@@ -672,7 +672,7 @@ namespace NKikimr::NDataStreams::V1 {
         ui32 writeSpeed = pqConfig.GetPartitionConfig().GetWriteSpeedInBytesPerSecond() / 1_KB;
         auto& description = *result.mutable_stream_description();
         description.set_stream_name(GetProtoRequest()->stream_name());
-        description.set_stream_arn(GetProtoRequest()->stream_name());  // Added by lpetrov02 for testing
+        description.set_stream_arn(GetProtoRequest()->stream_name());
         ui32 retentionPeriodHours = TInstant::Seconds(pqConfig.GetPartitionConfig().GetLifetimeSeconds()).Hours();
         description.set_retention_period_hours(retentionPeriodHours);
         description.set_write_quota_kb_per_sec(writeSpeed);