From bdd16964fc664db5aa076dbbfd39fbc096df9aca Mon Sep 17 00:00:00 2001 From: Aly Raffauf Date: Mon, 3 Aug 2026 01:45:30 -0400 Subject: [PATCH] Keep batched materializations compatible with state schema --- src/storage/materializations.rs | 4 ++-- src/storage/schema.rs | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/storage/materializations.rs b/src/storage/materializations.rs index daec64a..84d8833 100644 --- a/src/storage/materializations.rs +++ b/src/storage/materializations.rs @@ -13,7 +13,7 @@ impl StateStore { resulting_manifest: &Manifest, ) -> anyhow::Result<()> { self.connection.execute( - "INSERT INTO pending_materializations (folder_id, entries, resulting_manifest) VALUES (?1, ?2, ?3) ON CONFLICT(folder_id) DO UPDATE SET entries = excluded.entries, resulting_manifest = excluded.resulting_manifest", + "INSERT INTO pending_materializations (folder_id, entry, resulting_manifest) VALUES (?1, ?2, ?3) ON CONFLICT(folder_id) DO UPDATE SET entry = excluded.entry, resulting_manifest = excluded.resulting_manifest", params![folder_id.to_string(), serde_json::to_string(entries)?, serde_json::to_string(resulting_manifest)?], )?; Ok(()) @@ -24,7 +24,7 @@ impl StateStore { folder_id: FolderId, ) -> anyhow::Result> { self.connection.query_row( - "SELECT entries, resulting_manifest FROM pending_materializations WHERE folder_id = ?1", + "SELECT entry, resulting_manifest FROM pending_materializations WHERE folder_id = ?1", params![folder_id.to_string()], |row| Ok((row.get::<_, String>(0)?, row.get::<_, String>(1)?)), ).optional()?.map(|(entries, manifest)| Ok(PendingMaterialization { diff --git a/src/storage/schema.rs b/src/storage/schema.rs index 6fda89b..60dd4dd 100644 --- a/src/storage/schema.rs +++ b/src/storage/schema.rs @@ -57,7 +57,7 @@ const TABLE_STATEMENTS: &[&str] = &[ );", "CREATE TABLE IF NOT EXISTS pending_materializations ( folder_id TEXT PRIMARY KEY NOT NULL, - entries TEXT NOT NULL, + entry TEXT NOT NULL, resulting_manifest TEXT NOT NULL );", ]; -- 2.51.2