diff options
| author | ildar-khisambeev <ikhis@ydb.tech> | 2024-02-09 13:59:59 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-02-09 13:59:59 +0300 |
| commit | 46c8dba9b1a91cd44a302e78067832d09d9883df (patch) | |
| tree | ef5839bb3b47873ad00513a8a9ebd9d4dcc79110 | |
| parent | db527f78afca301a51755a23f4063841355dc333 (diff) | |
| download | ydb-46c8dba9b1a91cd44a302e78067832d09d9883df.tar.gz | |
LOGBROKER-8783 bugfix (#1713)
* bugfix
* unmute fixed test
| -rw-r--r-- | .github/config/muted_ya.txt | 1 | ||||
| -rw-r--r-- | ydb/public/sdk/cpp/client/ydb_federated_topic/impl/federated_read_session.cpp | 2 |
2 files changed, 1 insertions, 2 deletions
diff --git a/.github/config/muted_ya.txt b/.github/config/muted_ya.txt index 13419cac28..d645b979d9 100644 --- a/.github/config/muted_ya.txt +++ b/.github/config/muted_ya.txt @@ -49,7 +49,6 @@ ydb/library/actors/http/ut sole* ydb/library/yql/providers/generic/connector/tests sole* ydb/library/yql/providers/generic/connector/tests test.py.* ydb/public/lib/ydb_cli/topic/ut TTopicReaderTests.TestRun_ReadOneMessage -ydb/public/sdk/cpp/client/ydb_federated_topic/ut BasicUsage.SimpleHandlers ydb/public/sdk/cpp/client/ydb_persqueue_core/ut/with_offset_ranges_mode_ut RetryPolicy.RetryWithBatching ydb/public/sdk/cpp/client/ydb_persqueue_core/ut/with_offset_ranges_mode_ut RetryPolicy.TWriteSession_TestBrokenPolicy ydb/public/sdk/cpp/client/ydb_topic/ut BasicUsage.ConflictingWrites diff --git a/ydb/public/sdk/cpp/client/ydb_federated_topic/impl/federated_read_session.cpp b/ydb/public/sdk/cpp/client/ydb_federated_topic/impl/federated_read_session.cpp index df0bf1c8d0..7cfebed230 100644 --- a/ydb/public/sdk/cpp/client/ydb_federated_topic/impl/federated_read_session.cpp +++ b/ydb/public/sdk/cpp/client/ydb_federated_topic/impl/federated_read_session.cpp @@ -17,7 +17,7 @@ NTopic::TTopicClientSettings FromFederated(const TFederatedTopicClientSettings& template <typename TEvent, typename TFederatedEvent> typename std::function<void(TEvent&)> WrapFederatedHandler(std::function<void(TFederatedEvent&)> outerHandler, std::shared_ptr<TDbInfo> db, std::shared_ptr<TEventFederator> federator) { if (outerHandler) { - return [outerHandler, db = std::move(db), &federator](TEvent& ev) { + return [outerHandler, db = std::move(db), federator = std::move(federator)](TEvent& ev) { auto fev = federator->LocateFederate(ev, std::move(db)); return outerHandler(fev); }; |