Skip to content
Snippets Groups Projects
Commit a8aa09ae authored by Georgy Moshkin's avatar Georgy Moshkin :speech_balloon:
Browse files

fix: use a cas predicate for the migration progress updates

parent dc0ad29d
No related branches found
No related tags found
1 merge request!1254fix: fault-tolerant governor raft operations via compare-and-swap
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)))
};
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment