From 372d23b7ccf760400c3ffa0e1a84cd9bb75fc343 Mon Sep 17 00:00:00 2001 From: Nikita Sivukhin Date: Mon, 11 Aug 2025 16:52:18 +0400 Subject: [PATCH] handle schema changes in sync engine --- packages/turso-sync-engine/src/database_sync_operations.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/turso-sync-engine/src/database_sync_operations.rs b/packages/turso-sync-engine/src/database_sync_operations.rs index 0e8d145a6..f8667c5ab 100644 --- a/packages/turso-sync-engine/src/database_sync_operations.rs +++ b/packages/turso-sync-engine/src/database_sync_operations.rs @@ -326,6 +326,7 @@ pub async fn transfer_logical_changes( let iterate_opts = DatabaseChangesIteratorOpts { first_change_id: last_change_id.map(|x| x + 1), mode: DatabaseChangesIteratorMode::Apply, + ignore_schema_changes: false, ..Default::default() }; let mut changes = source.iterate_changes(iterate_opts)?; @@ -599,7 +600,6 @@ pub mod tests { conn1.execute("INSERT INTO t VALUES (1, 2), (3, 4), (5, 6)")?; let conn2 = db2.connect(&coro).await?; - conn2.execute("CREATE TABLE t(x, y)")?; transfer_logical_changes(&coro, &db1, &db2, "id-1", false).await?;