From 0bb6ed2c6d0a1b2a92fd64d95ec96360f5324bcf Mon Sep 17 00:00:00 2001 From: Bryce Date: Wed, 3 Jul 2024 08:54:58 -0700 Subject: [PATCH] Fixes rate limiting, adds more logs --- src/clj/auto_ap/square/core3.clj | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/clj/auto_ap/square/core3.clj b/src/clj/auto_ap/square/core3.clj index c3e6cc08..c35bccbe 100644 --- a/src/clj/auto_ap/square/core3.clj +++ b/src/clj/auto_ap/square/core3.clj @@ -35,7 +35,7 @@ (def manifold-api-stream (let [stream (s/stream 100)] (->> stream - (s/throttle 50) + (s/throttle 25) (s/map (fn [[request attempt response-deferred]] (de/catch (de/chain @@ -70,7 +70,7 @@ (fn [error] (de/error! response-deferred error))))) - (s/buffer 50) + (s/buffer 25) (s/realize-each) (s/consume (fn [_] #_(log/info ::request-completed @@ -402,7 +402,9 @@ (s/reduce into [])))) (de/catch (fn [e] (log/error ::cant-create-results - :exception e))))))) + :exception e + :client client + :location location))))))) (defn get-payment [client p]