diff --git a/src/backend/distributed/executor/local_executor.c b/src/backend/distributed/executor/local_executor.c index a4e0d123d..7c60049a4 100644 --- a/src/backend/distributed/executor/local_executor.c +++ b/src/backend/distributed/executor/local_executor.c @@ -151,8 +151,7 @@ ExecuteLocalTaskList(CitusScanState *scanState, List *taskList) * during execution. Record it to apply the restrictions related to * local execution. */ - if (!TransactionAccessedLocalPlacement && - task->anchorShardId != INVALID_SHARD_ID) + if (task->anchorShardId != INVALID_SHARD_ID) { TransactionAccessedLocalPlacement = true; }