Skip to content

Commit b8f5450

Browse files
committed
Fix active snapshot checks
1 parent 94d572f commit b8f5450

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/backend/executor/execMain.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -150,7 +150,7 @@ standard_ExecutorStart(QueryDesc *queryDesc, int eflags)
150150
Assert(queryDesc->estate == NULL);
151151

152152
/* caller must ensure the query's snapshot is active */
153-
Assert(GetActiveSnapshot() == queryDesc->snapshot);
153+
Assert((ActiveSnapshotSet() ? GetActiveSnapshot() : InvalidSnapshot) == queryDesc->snapshot);
154154

155155
/*
156156
* If the transaction is read-only, we need to check if any writes are
@@ -325,7 +325,7 @@ standard_ExecutorRun(QueryDesc *queryDesc,
325325
Assert(!(estate->es_top_eflags & EXEC_FLAG_EXPLAIN_ONLY));
326326

327327
/* caller must ensure the query's snapshot is active */
328-
Assert(GetActiveSnapshot() == estate->es_snapshot);
328+
Assert((ActiveSnapshotSet() ? GetActiveSnapshot() : InvalidSnapshot) == estate->es_snapshot);
329329

330330
/*
331331
* Switch into per-query memory context

0 commit comments

Comments
 (0)