⬆️ Update promesa library

This commit is contained in:
Andrey Antukh 2025-05-13 07:59:56 +02:00
parent 36b162b4fa
commit d8daea72de
2 changed files with 10 additions and 8 deletions

View file

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

View file

@ -30,7 +30,7 @@
funcool/tubax {:mvn/version "2021.05.20-0"} funcool/tubax {:mvn/version "2021.05.20-0"}
funcool/cuerdas {:mvn/version "2023.11.09-407"} funcool/cuerdas {:mvn/version "2023.11.09-407"}
funcool/promesa funcool/promesa
{:git/sha "0c5ed6ad033515a2df4b55addea044f60e9653d0" {:git/sha "6c14b06d9d64fae6e43c1463ce313f2fdc0d989b"
:git/url "https://github.com/funcool/promesa"} :git/url "https://github.com/funcool/promesa"}
funcool/datoteka funcool/datoteka