⬆️ Upgrade promesa library to latest version

That fixes a workaround introduced in previous commits
This commit is contained in:
Andrey Antukh 2025-05-22 09:14:01 +02:00
parent 949b6d1205
commit 172b70d8a7
2 changed files with 8 additions and 10 deletions

View file

@ -22,8 +22,7 @@
[datoteka.fs :as fs]
[integrant.core :as ig]
[promesa.exec :as px]
[promesa.exec.bulkhead :as pbh]
[promesa.protocols :as pt])
[promesa.exec.bulkhead :as pbh])
(:import
clojure.lang.ExceptionInfo
java.util.concurrent.atomic.AtomicLong))
@ -179,13 +178,12 @@
(measure metrics mlabels stats nil)
(log "enqueued" req-id stats limit-id limit-label limit-params nil))
;; WORKAROUND: this is a temporal change until the bug is fixed in funcool/promesa
@(pt/-submit! limiter (fn []
(let [elapsed (tpoint)
stats (pbh/get-stats limiter)]
(measure metrics mlabels stats elapsed)
(log "acquired" req-id stats limit-id limit-label limit-params elapsed)
(handler))))
(px/invoke! limiter (fn []
(let [elapsed (tpoint)
stats (pbh/get-stats limiter)]
(measure metrics mlabels stats elapsed)
(log "acquired" req-id stats limit-id limit-label limit-params elapsed)
(handler))))
(catch ExceptionInfo cause
(let [{:keys [type code]} (ex-data cause)]