From 4fa897fbb657be81ff2ff4f6dd9e56c490f5231e Mon Sep 17 00:00:00 2001 From: Ruben Fiszel Date: Thu, 13 Feb 2025 17:51:03 +0100 Subject: [PATCH] remove v5 migration --- backend/windmill-api/src/db.rs | 42 +++++++++++++++++----------------- 1 file changed, 21 insertions(+), 21 deletions(-) diff --git a/backend/windmill-api/src/db.rs b/backend/windmill-api/src/db.rs index 5bb273c1db..9adae014d3 100644 --- a/backend/windmill-api/src/db.rs +++ b/backend/windmill-api/src/db.rs @@ -225,27 +225,27 @@ pub async fn migrate(db: &DB) -> Result<(), Error> { } }); - if !has_done_migration(db, "v2_finalize_disable_sync").await { - let db2 = db.clone(); - let _ = tokio::task::spawn(async move { - loop { - if !*MIN_VERSION_IS_AT_LEAST_1_461.read().await { - tracing::info!("Waiting for all workers to be at least version 1.461 before applying v2 finalize migration, sleeping for 5s..."); - tokio::time::sleep(Duration::from_secs(5)).await; - continue; - } - if let Err(err) = v2_finalize(&db2).await { - tracing::error!( - "{err:#}: Could not apply v2 finalize migration, retry in 30s.." - ); - tokio::time::sleep(Duration::from_secs(30)).await; - continue; - } - tracing::info!("v2 finalization step successfully applied."); - break; - } - }); - } + // if !has_done_migration(db, "v2_finalize_disable_sync").await { + // let db2 = db.clone(); + // let _ = tokio::task::spawn(async move { + // loop { + // if !*MIN_VERSION_IS_AT_LEAST_1_461.read().await { + // tracing::info!("Waiting for all workers to be at least version 1.461 before applying v2 finalize migration, sleeping for 5s..."); + // tokio::time::sleep(Duration::from_secs(5)).await; + // continue; + // } + // if let Err(err) = v2_finalize(&db2).await { + // tracing::error!( + // "{err:#}: Could not apply v2 finalize migration, retry in 30s.." + // ); + // tokio::time::sleep(Duration::from_secs(30)).await; + // continue; + // } + // tracing::info!("v2 finalization step successfully applied."); + // break; + // } + // }); + // } Ok(()) }