diff options
Diffstat (limited to 'src/fe_utils/parallel_slot.c')
| -rw-r--r-- | src/fe_utils/parallel_slot.c | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/fe_utils/parallel_slot.c b/src/fe_utils/parallel_slot.c index 02368551f4e..aca238bce9f 100644 --- a/src/fe_utils/parallel_slot.c +++ b/src/fe_utils/parallel_slot.c @@ -475,6 +475,9 @@ ParallelSlotsWaitCompletion(ParallelSlotArray *sa) continue; if (!consumeQueryResult(&sa->slots[i])) return false; + /* Mark connection as idle */ + sa->slots[i].inUse = false; + ParallelSlotClearHandler(&sa->slots[i]); } return true; |