From dbfd45ea91329d9483a1c863d3caaf689d36730b Mon Sep 17 00:00:00 2001 From: Ruben Fiszel Date: Wed, 7 Feb 2024 23:39:09 +0100 Subject: [PATCH] improve custom windmill migration --- backend/windmill-api/src/db.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/backend/windmill-api/src/db.rs b/backend/windmill-api/src/db.rs index dcf46ea534..504b1de0cb 100644 --- a/backend/windmill-api/src/db.rs +++ b/backend/windmill-api/src/db.rs @@ -116,7 +116,7 @@ async fn windmill_migrations(migrator: &mut CustomMigrator, db: &DB) -> Result<( { migrator.lock().await?; let has_done_migration = sqlx::query_scalar!( - "SELECT EXISTS(SELECT name FROM windmill_migrations WHERE name = 'bypassrls_1')", + "SELECT EXISTS(SELECT name FROM windmill_migrations WHERE name = 'bypassrls_1-2')", ) .fetch_one(db) .await? @@ -126,9 +126,9 @@ async fn windmill_migrations(migrator: &mut CustomMigrator, db: &DB) -> Result<( let query = include_str!("../../custom_migrations/bypassrls_1.sql"); tracing::info!("Applying bypassrls_1.sql"); let mut tx: sqlx::Transaction<'_, Postgres> = db.begin().await?; - tx.execute_many(query); + tx.execute(query).await?; tracing::info!("Applied bypassrls_1.sql"); - sqlx::query!("INSERT INTO windmill_migrations (name) VALUES ('bypassrls_1')") + sqlx::query!("INSERT INTO windmill_migrations (name) VALUES ('bypassrls_1-2')") .execute(&mut *tx) .await?; tx.commit().await?;