Skip to content

Commit ee88833

Browse files
committed
store: Log more when copy workers have an error
1 parent 16521ee commit ee88833

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

store/postgres/src/copy.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1091,6 +1091,7 @@ impl Connection {
10911091
W::Err(e) => {
10921092
// This is a panic in the background task. We need to
10931093
// cancel all other tasks and return the error
1094+
error!(self.logger, "copy worker panicked: {}", e);
10941095
self.cancel_workers(progress, workers).await;
10951096
return Err(e);
10961097
}
@@ -1115,6 +1116,7 @@ impl Connection {
11151116
return Ok(Status::Cancelled);
11161117
}
11171118
(Err(e), _) => {
1119+
error!(self.logger, "copy worker had an error: {}", e);
11181120
self.cancel_workers(progress, workers).await;
11191121
return Err(e);
11201122
}

0 commit comments

Comments
 (0)