fix exception processing (#11728)

ivanmorozov333 · web-flow · commit c5d16f6b6b52 · 2024-11-19T09:04:18.000Z
diff --git a/ydb/core/kqp/compute_actor/kqp_scan_fetcher_actor.cpp b/ydb/core/kqp/compute_actor/kqp_scan_fetcher_actor.cpp
@@ -472,7 +472,7 @@ std::unique_ptr<NKikimr::TEvDataShard::TEvKqpScan> 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
@@ -118,7 +118,7 @@ class TKqpScanFetcherActor: public NActors::TActorBootstrapped<TKqpScanFetcherAc
 
     void HandleExecute(TEvKqpCompute::TEvScanData::TPtr& ev);
 
-    void ProcessPendingScanDataItem(TEvKqpCompute::TEvScanData::TPtr& ev, const TInstant& enqueuedAt) noexcept;
+    void ProcessPendingScanDataItem(TEvKqpCompute::TEvScanData::TPtr& ev, const TInstant& enqueuedAt);
 
     void ProcessScanData();
 

Original file line number	Diff line number	Diff line change
`@@ -472,7 +472,7 @@ std::unique_ptr<NKikimr::TEvDataShard::TEvKqpScan> TKqpScanFetcherActor::BuildEv`
`472`	`472`	`return ev;`
`473`	`473`	`}`
`474`	`474`
`475`		`-void TKqpScanFetcherActor::ProcessPendingScanDataItem(TEvKqpCompute::TEvScanData::TPtr& ev, const TInstant& enqueuedAt) noexcept {`
	`475`	`+void TKqpScanFetcherActor::ProcessPendingScanDataItem(TEvKqpCompute::TEvScanData::TPtr& ev, const TInstant& enqueuedAt) {`
`476`	`476`	`auto& msg = *ev->Get();`
`477`	`477`
`478`	`478`	`auto state = InFlightShards.GetShardStateByActorId(ev->Sender);`