prevents duplicates

warehouse/src/load.rs

@@ -57,7 +57,11 @@ pub async fn commit_batch_query(pool: &SqlitePool, batch_accounts: &[WarehouseAc
         b.push_bind(acc.address.to_hex_literal()).push_bind(true);
     });
 
+    // makes sure the txs don't fail on repeated attempts to add users
+    query_builder.push("ON CONFLICT (account_address) DO NOTHING");
+
     let query = query_builder.build();
-    query.execute(pool).await?;
+    let _res = query.execute(pool).await?;
+
     Ok(())
 }

warehouse/tests/test_load.rs

@@ -61,7 +61,12 @@ async fn batch_duplicates_fail_gracefully(pool: SqlitePool) -> anyhow::Result<()
       vec_acct.push(acc);
     }
 
+  // should not fail if duplicates exists on same batch
   libra_warehouse::load::commit_batch_query(&pool, &vec_acct).await?;
+
+  // also should not fail if duplicates are on separate batches
+  libra_warehouse::load::commit_batch_query(&pool, &vec_acct).await?;
+
   Ok(())
 }