From 10c96c5150f37438373387fc518673ee4ef08bde Mon Sep 17 00:00:00 2001 From: Giorgi Merebashvili Date: Sat, 28 Feb 2026 18:24:22 +0400 Subject: [PATCH 1/2] fix(worker): Fix client library version check for older workers --- Cargo.lock | 2 +- crates/fluxqueue-worker/Cargo.toml | 2 +- crates/fluxqueue-worker/src/worker.rs | 9 +++++---- 3 files changed, 7 insertions(+), 6 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index cf90b63..636771f 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -272,7 +272,7 @@ dependencies = [ [[package]] name = "fluxqueue-worker" -version = "0.3.0-rc1" +version = "0.2.1" dependencies = [ "anyhow", "chrono", diff --git a/crates/fluxqueue-worker/Cargo.toml b/crates/fluxqueue-worker/Cargo.toml index 662448d..aceb0ee 100644 --- a/crates/fluxqueue-worker/Cargo.toml +++ b/crates/fluxqueue-worker/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "fluxqueue-worker" -version = "0.3.0-rc1" +version = "0.2.1" edition = "2024" [lib] diff --git a/crates/fluxqueue-worker/src/worker.rs b/crates/fluxqueue-worker/src/worker.rs index acf824b..0bcf4e8 100644 --- a/crates/fluxqueue-worker/src/worker.rs +++ b/crates/fluxqueue-worker/src/worker.rs @@ -347,14 +347,15 @@ fn check_client_library_version() -> Result<()> { })?; let comparison = compare_versions(worker_version, &library_version); + if comparison == -1 { - tracing::warn!( - "Worker version '{}' is older than client library '{}'. For full functionality, update the worker to match the client version.", + return Err(anyhow!( + "Worker version '{}' is older than client library '{}'. \ + Worker might not work properly, update the worker to match the client version.", worker_version, &library_version - ); + )); } - if comparison == 1 { return Err(anyhow!( "Minimum required client library version is: {}, found: {}", From 59a746a06fb33f4fcc058ab1d3b4fa08a84d0b82 Mon Sep 17 00:00:00 2001 From: Giorgi Merebashvili Date: Sat, 28 Feb 2026 18:28:26 +0400 Subject: [PATCH 2/2] Fix version --- Cargo.lock | 2 +- crates/fluxqueue-worker/Cargo.toml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index 636771f..cf90b63 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -272,7 +272,7 @@ dependencies = [ [[package]] name = "fluxqueue-worker" -version = "0.2.1" +version = "0.3.0-rc1" dependencies = [ "anyhow", "chrono", diff --git a/crates/fluxqueue-worker/Cargo.toml b/crates/fluxqueue-worker/Cargo.toml index aceb0ee..662448d 100644 --- a/crates/fluxqueue-worker/Cargo.toml +++ b/crates/fluxqueue-worker/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "fluxqueue-worker" -version = "0.2.1" +version = "0.3.0-rc1" edition = "2024" [lib]