Skip to content

Commit c82b389

Browse files
authored
Merge 9e85a5e into 9408283
2 parents 9408283 + 9e85a5e commit c82b389

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

ydb/core/kqp/session_actor/kqp_query_state.h

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -311,18 +311,18 @@ class TKqpQueryState : public TNonCopyable {
311311
}
312312

313313
bool NeedPersistentSnapshot() const {
314-
auto type = GetType();
315-
if (type == NKikimrKqp::QUERY_TYPE_SQL_GENERIC_CONCURRENT_QUERY ||
316-
type == NKikimrKqp::QUERY_TYPE_SQL_GENERIC_QUERY) {
317-
return ::NKikimr::NKqp::HasOlapTableReadInTx(PreparedQuery->GetPhysicalQuery());
318-
}
319314
return (
320315
type == NKikimrKqp::QUERY_TYPE_SQL_SCAN ||
321316
type == NKikimrKqp::QUERY_TYPE_AST_SCAN
322317
);
323318
}
324319

325320
bool NeedSnapshot(const NYql::TKikimrConfiguration& config) const {
321+
auto type = GetType();
322+
if (type == NKikimrKqp::QUERY_TYPE_SQL_GENERIC_CONCURRENT_QUERY ||
323+
type == NKikimrKqp::QUERY_TYPE_SQL_GENERIC_QUERY) {
324+
return ::NKikimr::NKqp::HasOlapTableReadInTx(PreparedQuery->GetPhysicalQuery());
325+
}
326326
return ::NKikimr::NKqp::NeedSnapshot(*TxCtx, config, /*rollback*/ false, Commit, PreparedQuery->GetPhysicalQuery());
327327
}
328328

0 commit comments

Comments
 (0)