Skip to content

Commit b8d7260

Browse files
committed
Refactor a little bit
1 parent 3e9e20c commit b8d7260

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

ydb/core/kqp/executer_actor/kqp_data_executer.cpp

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2629,10 +2629,6 @@ class TKqpDataExecuter : public TKqpExecuterBase<TKqpDataExecuter, EExecType::Da
26292629
Send(MakePipePerNodeCacheID(true), new TEvPipeCache::TEvUnlink(0));
26302630
}
26312631

2632-
// Actualize stats with the last stats from terminated CAs, but keep the status.
2633-
YQL_ENSURE(ResponseEv);
2634-
FillResponseStats(ResponseEv->Record.GetResponse().GetStatus());
2635-
26362632
TBase::PassAway();
26372633
}
26382634

ydb/core/kqp/executer_actor/kqp_executer_impl.h

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1872,6 +1872,9 @@ class TKqpExecuterBase : public TActorBootstrapped<TDerived> {
18721872

18731873
void PassAway() override {
18741874
YQL_ENSURE(AlreadyReplied && ResponseEv);
1875+
1876+
// Actualize stats with the last stats from terminated CAs, but keep the status.
1877+
FillResponseStats(ResponseEv->Record.GetResponse().GetStatus());
18751878
this->Send(Target, ResponseEv.release());
18761879

18771880
for (auto channelPair: ResultChannelProxies) {

0 commit comments

Comments
 (0)