diff options
author | lpetrov02 <lpetrov02@yandex-team.com> | 2023-02-16 10:20:45 +0300 |
---|---|---|
committer | lpetrov02 <lpetrov02@yandex-team.com> | 2023-02-16 10:20:45 +0300 |
commit | 81df0ab704d8b172085f8e97c236ca88c102d907 (patch) | |
tree | e5467b991d209f02fb7805c1f0ce30f548415a35 | |
parent | fe2e305243b3643740b1178a9893de33e94a1367 (diff) | |
download | ydb-81df0ab704d8b172085f8e97c236ca88c102d907.tar.gz |
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'
-rw-r--r-- | ydb/services/datastreams/datastreams_proxy.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/services/datastreams/datastreams_proxy.cpp b/ydb/services/datastreams/datastreams_proxy.cpp index a12a8e1288b..bb553fb1d4f 100644 --- a/ydb/services/datastreams/datastreams_proxy.cpp +++ b/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); |