diff --git a/src/clj/auto_ap/yodlee/core.clj b/src/clj/auto_ap/yodlee/core.clj
index 93aab1d8..2fe9e198 100644
--- a/src/clj/auto_ap/yodlee/core.clj
+++ b/src/clj/auto_ap/yodlee/core.clj
@@ -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 []