diff options
author | komels <komels@yandex-team.ru> | 2022-06-06 10:13:49 +0300 |
---|---|---|
committer | komels <komels@yandex-team.ru> | 2022-06-06 10:13:49 +0300 |
commit | 1e2646c24f77e641a759006867b0b60d17747f97 (patch) | |
tree | 50e49f84e70f74375813c005d47b64798bf869c9 | |
parent | c793e781f74d8f6190daa79ab6810a68ac41e9b3 (diff) | |
download | ydb-1e2646c24f77e641a759006867b0b60d17747f97.tar.gz |
Fix alter_topic() for tests
ref:b44fe73560c755ba07b34f5a05e1eb2578aba778
-rw-r--r-- | ydb/core/testlib/test_pq_client.h | 10 |
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; |