We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 03bdabc commit e14204dCopy full SHA for e14204d
rust/property-defs-rs/src/v2_batch_ingestion.rs
@@ -306,6 +306,27 @@ pub async fn process_batch_v2(
306
}
307
308
309
+
310
+ // if any of the batches are full, execute them now
311
+ if handles.is_empty() {
312
+ continue;
313
+ }
314
+ let to_exec = handles;
315
+ handles = vec![];
316
+ for handle in to_exec {
317
+ match handle.await {
318
+ // metrics are statted in write_*_batch methods so we just log here
319
+ Ok(result) => match result {
320
+ Ok(_) => continue,
321
+ Err(db_err) => {
322
+ error!("Batch write exhausted retries: {:?}", db_err);
323
324
+ },
325
+ Err(join_err) => {
326
+ warn!("Batch query JoinError: {:?}", join_err);
327
328
329
330
331
332
// ensure partial batches are flushed to Postgres too
0 commit comments