Skip to content

Commit e6f55b1

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 baf3324 commit e6f55b1

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

store/postgres/src/copy.rs

+1
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)