summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/backend/tcop/pquery.c3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/backend/tcop/pquery.c b/src/backend/tcop/pquery.c
index 134dc6dd24..cb97be771f 100644
--- a/src/backend/tcop/pquery.c
+++ b/src/backend/tcop/pquery.c
@@ -2354,7 +2354,8 @@ AdvanceProducingPortal(Portal portal, bool can_wait)
/* Execute query and dispatch tuples via dest receiver */
#define PRODUCE_TUPLES 100
PushActiveSnapshot(queryDesc->snapshot);
- ExecutorRun(queryDesc, ForwardScanDirection, PRODUCE_TUPLES, true);
+ ExecutorRun(queryDesc, ForwardScanDirection, PRODUCE_TUPLES,
+ portal->run_once);
PopActiveSnapshot();
if (queryDesc->estate->es_processed < PRODUCE_TUPLES)