yodlee less error prone?
This commit is contained in:
@@ -304,7 +304,11 @@
|
||||
(map (fn [provider-account]
|
||||
(lc/with-context {:provider-account-id (:id provider-account)}
|
||||
(get-provider-account-detail (:id provider-account)))))
|
||||
(async/to-chan provider-accounts))
|
||||
(async/to-chan provider-accounts)
|
||||
true
|
||||
(fn [e]
|
||||
(lc/with-context {:source "Yodlee"}
|
||||
(log/error "Yodlee pipeline error" e))))
|
||||
(async/<!! (async/into [] output-chan)))))
|
||||
|
||||
(defn concurrent-get-accounts-for-providers [provider-account-ids]
|
||||
@@ -316,7 +320,11 @@
|
||||
(lc/with-context {:provider-account-id provider-account-id}
|
||||
[provider-account-id
|
||||
(get-accounts-for-provider-account provider-account-id)])))
|
||||
(async/to-chan provider-account-ids))
|
||||
(async/to-chan provider-account-ids)
|
||||
true
|
||||
(fn [e]
|
||||
(lc/with-context {:source "Yodlee"}
|
||||
(log/error "Yodlee pipeline error" e))))
|
||||
(async/<!! (async/into {} output-chan))))
|
||||
|
||||
(defn get-provider-accounts-with-accounts []
|
||||
|
||||
Reference in New Issue
Block a user