Skip to content

Commit ef63345

Browse files
authored
fix(worker): Fix client library version check for older workers (#129)
* fix(worker): Fix client library version check for older workers * Fix version
1 parent 9ee8ce6 commit ef63345

1 file changed

Lines changed: 5 additions & 4 deletions

File tree

crates/fluxqueue-worker/src/worker.rs

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -347,14 +347,15 @@ fn check_client_library_version() -> Result<()> {
347347
})?;
348348

349349
let comparison = compare_versions(worker_version, &library_version);
350+
350351
if comparison == -1 {
351-
tracing::warn!(
352-
"Worker version '{}' is older than client library '{}'. For full functionality, update the worker to match the client version.",
352+
return Err(anyhow!(
353+
"Worker version '{}' is older than client library '{}'. \
354+
Worker might not work properly, update the worker to match the client version.",
353355
worker_version,
354356
&library_version
355-
);
357+
));
356358
}
357-
358359
if comparison == 1 {
359360
return Err(anyhow!(
360361
"Minimum required client library version is: {}, found: {}",

0 commit comments

Comments
 (0)