From 6c3e07e9c73c5e6721201692003fe9f84b3e5e58 Mon Sep 17 00:00:00 2001 From: Jack Amadeo Date: Sat, 18 Oct 2025 17:38:42 -0400 Subject: [PATCH] turn off WAL (#5203) --- crates/goose/src/session/session_manager.rs | 13 +++---------- 1 file changed, 3 insertions(+), 10 deletions(-) diff --git a/crates/goose/src/session/session_manager.rs b/crates/goose/src/session/session_manager.rs index 0002d419..669508ff 100644 --- a/crates/goose/src/session/session_manager.rs +++ b/crates/goose/src/session/session_manager.rs @@ -353,8 +353,7 @@ impl SessionStorage { let options = SqliteConnectOptions::new() .filename(db_path) .create_if_missing(create_if_missing) - .busy_timeout(std::time::Duration::from_secs(5)) - .journal_mode(sqlx::sqlite::SqliteJournalMode::Wal); + .busy_timeout(std::time::Duration::from_secs(5)); sqlx::SqlitePool::connect_with(options).await.map_err(|e| { anyhow::anyhow!( @@ -630,7 +629,7 @@ impl SessionStorage { async fn create_session(&self, working_dir: PathBuf, description: String) -> Result { let today = chrono::Utc::now().format("%Y%m%d").to_string(); - let session_id = sqlx::query_as( + Ok(sqlx::query_as( r#" INSERT INTO sessions (id, description, working_dir, extension_data) VALUES ( @@ -651,13 +650,7 @@ impl SessionStorage { .bind(&description) .bind(working_dir.to_string_lossy().as_ref()) .fetch_one(&self.pool) - .await?; - - sqlx::query("PRAGMA wal_checkpoint") - .execute(&self.pool) - .await?; - - Ok(session_id) + .await?) } async fn get_session(&self, id: &str, include_messages: bool) -> Result {