notid/integreat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

a variety of bug fixes.

Browse Source
This commit is contained in:
Bryce
2023-09-29 09:05:17 -07:00
parent 829c857122
commit f8b76b6c2c
6 changed files with 28 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/clj/auto_ap/square/core3.clj
View File

@@ -34,7 +34,7 @@
(def manifold-api-stream
(let [stream (s/stream 100)]
(->> stream
(s/throttle 80)
(s/throttle 50)
(s/map (fn [[request attempt response-deferred]]
(de/catch
(de/chain
@@ -47,8 +47,8 @@
:background-job "Square 3")
(try
(client/request (assoc request
:socket-timeout 5000
:connection-timeout 5000
:socket-timeout 10000
:connection-timeout 10000
#_#_:connection-request-timeout 5000
:as :json))
(catch Throwable e
@@ -60,7 +60,7 @@
(if (>= attempt 5)
(throw e)
(de/chain
(mt/in 1000 (fn [] 1))
(mt/in 10000 (fn [] 1))
(fn [_] (de/recur (inc attempt)))))))
(de/chain identity)))
(fn [result]
@@ -383,7 +383,7 @@
(daily-results client location (time/plus (time/now) (time/days -7)) (time/now)))
([client location start end]
(capture-context->lc
(->
(->
(de/chain (search client location start end)
(fn [search-results]
(->> (or search-results [])