From 336b24064c869b5ac2fc9135a8f0f57022138c27 Mon Sep 17 00:00:00 2001 From: Michiel de Mare Date: Tue, 10 Sep 2024 15:52:34 +0200 Subject: [PATCH] expired lock: throw error instead of logging (#330) --- src/nl/surf/eduhub_rio_mapper/worker.clj | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/nl/surf/eduhub_rio_mapper/worker.clj b/src/nl/surf/eduhub_rio_mapper/worker.clj index d5b0cd0a..de13eb73 100644 --- a/src/nl/surf/eduhub_rio_mapper/worker.clj +++ b/src/nl/surf/eduhub_rio_mapper/worker.clj @@ -63,7 +63,7 @@ lua-result (car/wcar redis-conn (car/lua lua-script {:k k} {:token token}))] (assert (number? lua-result)) (when (not= 1 lua-result) - (log/error (str "Lock " k " lost before release!"))))) + (throw (ex-info "Lock lost before release!" {:lock-name k}))))) (defn extend-lock! "Extend TTL on lock on `queue` with `token` by `ttl-ms`. @@ -80,7 +80,7 @@ lua-result (car/wcar redis-conn (car/lua lua-script {:k k} {:token token, :ttl-ms ttl-ms}))] (assert (number? lua-result)) (when (not= 1 lua-result) - (log/error (str "Lock lost before extend!" {:lock-name k}))))) + (throw (ex-info "Lock lost before extend!" {:lock-name k}))))) (defn- queue-key [config queue] (prefix-key config (str "queue:" queue)))