Skip to content

Commit c3f80cf

Browse files
committed
store: Do not drop the default copy connection when running out of work
When the default worker finished while other workers were still copying, and there was no more work to do, we inadvertently dropped the default connection.
1 parent 17360f5 commit c3f80cf

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

store/postgres/src/copy.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1020,6 +1020,7 @@ impl Connection {
10201020
return None;
10211021
};
10221022
let Some(table) = state.unfinished.pop() else {
1023+
self.conn = Some(conn);
10231024
return None;
10241025
};
10251026

0 commit comments

Comments
 (0)