From accade6b0b7b40d94e50fdace849dc16f0c16846 Mon Sep 17 00:00:00 2001 From: ivanmorozov333 Date: Tue, 19 Nov 2024 12:04:18 +0300 Subject: [PATCH] fix exception processing (#11728) --- ydb/core/kqp/compute_actor/kqp_scan_fetcher_actor.cpp | 2 +- ydb/core/kqp/compute_actor/kqp_scan_fetcher_actor.h | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/ydb/core/kqp/compute_actor/kqp_scan_fetcher_actor.cpp b/ydb/core/kqp/compute_actor/kqp_scan_fetcher_actor.cpp index 73f4c86398b9..85b95c78733b 100644 --- a/ydb/core/kqp/compute_actor/kqp_scan_fetcher_actor.cpp +++ b/ydb/core/kqp/compute_actor/kqp_scan_fetcher_actor.cpp @@ -469,7 +469,7 @@ std::unique_ptr TKqpScanFetcherActor::BuildEv return ev; } -void TKqpScanFetcherActor::ProcessPendingScanDataItem(TEvKqpCompute::TEvScanData::TPtr& ev, const TInstant& enqueuedAt) noexcept { +void TKqpScanFetcherActor::ProcessPendingScanDataItem(TEvKqpCompute::TEvScanData::TPtr& ev, const TInstant& enqueuedAt) { auto& msg = *ev->Get(); auto state = InFlightShards.GetShardStateByActorId(ev->Sender); diff --git a/ydb/core/kqp/compute_actor/kqp_scan_fetcher_actor.h b/ydb/core/kqp/compute_actor/kqp_scan_fetcher_actor.h index 0bd2bfc1d58b..64d7041d7218 100644 --- a/ydb/core/kqp/compute_actor/kqp_scan_fetcher_actor.h +++ b/ydb/core/kqp/compute_actor/kqp_scan_fetcher_actor.h @@ -118,7 +118,7 @@ class TKqpScanFetcherActor: public NActors::TActorBootstrapped