diff --git a/src/plc_pg.rs b/src/plc_pg.rs index a139ee6..166d6f4 100644 --- a/src/plc_pg.rs +++ b/src/plc_pg.rs @@ -93,6 +93,7 @@ pub async fn write_bulk( let t0 = Instant::now(); let tx = client.transaction().await?; + tx.execute("SET LOCAL synchronous_commit = off", &[]).await?; let t_step = Instant::now(); for table in ["operations", "dids"] {