Skip to content

Commit 6a6cd49

Browse files
committed
Move LWTRACK before co_await to prevent ResponseEv race
1 parent 048ee29 commit 6a6cd49

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

ydb/core/kqp/executer_actor/kqp_executer_impl.h

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -606,6 +606,8 @@ class TKqpExecuterBase : public TActor<TDerived> {
606606
const auto& databaseId = GetUserRequestContext()->DatabaseId;
607607
const auto& poolId = GetUserRequestContext()->PoolId.empty() ? NResourcePool::DEFAULT_POOL_ID : GetUserRequestContext()->PoolId;
608608

609+
LWTRACK(KqpBaseExecuterHandleReady, ResponseEv->Orbit, TxId);
610+
609611
if (!databaseId.empty() && (poolId != NResourcePool::DEFAULT_POOL_ID || AccountDefaultPoolInScheduler)) {
610612
const auto schedulerServiceId = MakeKqpSchedulerServiceId(SelfId().NodeId());
611613

@@ -645,7 +647,6 @@ class TKqpExecuterBase : public TActor<TDerived> {
645647
break;
646648
}
647649

648-
LWTRACK(KqpBaseExecuterHandleReady, ResponseEv->Orbit, TxId);
649650
if (IsDebugLogEnabled()) {
650651
for (auto& tx : Request.Transactions) {
651652
LOG_D("Executing physical tx, type: " << (ui32) tx.Body->GetType() << ", stages: " << tx.Body->StagesSize());

0 commit comments

Comments
 (0)