aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorkomels <komels@yandex-team.ru>2022-06-06 10:13:49 +0300
committerkomels <komels@yandex-team.ru>2022-06-06 10:13:49 +0300
commit1e2646c24f77e641a759006867b0b60d17747f97 (patch)
tree50e49f84e70f74375813c005d47b64798bf869c9
parentc793e781f74d8f6190daa79ab6810a68ac41e9b3 (diff)
downloadydb-1e2646c24f77e641a759006867b0b60d17747f97.tar.gz
Fix alter_topic() for tests
ref:b44fe73560c755ba07b34f5a05e1eb2578aba778
-rw-r--r--ydb/core/testlib/test_pq_client.h10
1 files changed, 7 insertions, 3 deletions
diff --git a/ydb/core/testlib/test_pq_client.h b/ydb/core/testlib/test_pq_client.h
index 57d59cfcb99..bfb871370b8 100644
--- a/ydb/core/testlib/test_pq_client.h
+++ b/ydb/core/testlib/test_pq_client.h
@@ -208,14 +208,18 @@ struct TRequestAlterPQ {
auto req = request->Record.MutableMetaRequest()->MutableCmdChangeTopic();
req->SetTopic(Topic);
req->SetNumPartitions(NumParts);
+
if (CacheSize) {
- auto config = req->MutableConfig();
+ auto* config = req->MutableConfig();
+ config->SetTopicName(Topic);
config->SetCacheSize(CacheSize);
}
if (FillPartitionConfig) {
- req->MutableConfig()->MutablePartitionConfig()->SetLifetimeSeconds(LifetimeS);
+ auto* config = req->MutableConfig();
+ config->SetTopicName(Topic);
+ config->MutablePartitionConfig()->SetLifetimeSeconds(LifetimeS);
if (MirrorFrom) {
- req->MutableConfig()->MutablePartitionConfig()->MutableMirrorFrom()->CopyFrom(MirrorFrom.value());
+ config->MutablePartitionConfig()->MutableMirrorFrom()->CopyFrom(MirrorFrom.value());
}
}
return request;