diff --git a/src/ingestion/db.rs b/src/ingestion/db.rs index 1dc61a3..648c917 100644 --- a/src/ingestion/db.rs +++ b/src/ingestion/db.rs @@ -28,7 +28,7 @@ pub async fn insert( .map(|row| MonzoRow::into_insertion(row, account_id)) .collect::, _>>()?; - for insertions in insertions.chunks(400) { + for insertions in insertions.chunks(200) { let (new_or_updated_insertions, inserted_transaction_ids) = whittle_insertions(insertions, db).await?;