We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 68c3804 commit 382a92fCopy full SHA for 382a92f
1 file changed
store/postgres/src/copy.rs
@@ -748,10 +748,19 @@ impl CopyTableWorker {
748
break status;
749
}
750
Err(StoreError::StatementTimeout) => {
751
+ let timeout = ENV_VARS
752
+ .store
753
+ .batch_timeout
754
+ .map(|t| t.as_secs().to_string())
755
+ .unwrap_or_else(|| "unlimted".to_string());
756
warn!(
- logger,
- "Current batch took longer than GRAPH_STORE_BATCH_TIMEOUT seconds. Retrying with a smaller batch size."
- );
757
+ logger,
758
+ "Current batch timed out. Retrying with a smaller batch size.";
759
+ "timeout_s" => timeout,
760
+ "table" => self.table.dst.qualified_name.as_str(),
761
+ "current_vid" => self.table.batcher.next_vid(),
762
+ "current_batch_size" => self.table.batcher.batch_size(),
763
+ );
764
765
Err(e) => {
766
return Err(e);
0 commit comments