Skip to content

Commit 2574b37

Browse files
committed
store: Improve errors from Writer.check_queue_running
1 parent 9ac5a43 commit 2574b37

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

store/postgres/src/writable.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -961,6 +961,8 @@ impl Writer {
961961
match self {
962962
Writer::Sync(_) => Ok(()),
963963
Writer::Async { join_handle, queue } => {
964+
// If there was an error, report that instead of a naked 'writer not running'
965+
queue.check_err()?;
964966
if join_handle.is_finished() {
965967
Err(constraint_violation!(
966968
"Subgraph writer for {} is not running",

0 commit comments

Comments
 (0)