From a8aa09ae05c69e1e6f787e8e2a6535dbd7bf942f Mon Sep 17 00:00:00 2001
From: Georgy Moshkin <gmoshkin@picodata.io>
Date: Mon, 2 Sep 2024 16:59:03 +0300
Subject: [PATCH] fix: use a cas predicate for the migration progress updates
---
src/plugin/migration.rs | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/src/plugin/migration.rs b/src/plugin/migration.rs
index e0eb2037dd..68b589945e 100644
--- a/src/plugin/migration.rs
+++ b/src/plugin/migration.rs
@@ -1,3 +1,4 @@
+use crate::cas;
use crate::cbus::ENDPOINT_NAME;
use crate::plugin::reenterable_plugin_cas_request;
use crate::plugin::PreconditionCheckResult;
@@ -458,7 +459,7 @@ fn down_single_file_with_commit(
&[plugin_name, &queries.filename_from_manifest],
ADMIN_ID,
)?;
- let ranges = vec![];
+ let ranges = vec![cas::Range::for_dml(&dml)?];
Ok(PreconditionCheckResult::DoOp((Op::Dml(dml), ranges)))
};
@@ -558,7 +559,7 @@ pub fn apply_up_migrations(
),
ADMIN_ID,
)?;
- let ranges = vec![];
+ let ranges = vec![cas::Range::for_dml(&dml)?];
Ok(PreconditionCheckResult::DoOp((Op::Dml(dml), ranges)))
};
--
GitLab