         user-node {:name (:_id user) :value (:name user) :group 1}
         pubs (into #{} (map :target (mc/find-maps @db "pubs" {:source (:_id user) :ts day})))
         links (->> (mc/find-maps @db "sources" {:ts day :target {$in pubs}})
-                   (map (comp find-links
+                   (pmap (comp find-links
                               (fn [{:keys [source target ts]}]
                                 {:source target
                                  :target (:_id user)

  (:require [monger.collection :as mc]
            [monger.core :as mg]
            [aprint.core :refer [ap]]
            [monger.joda-time]
            [monger.operators :refer :all]
            [monger.query :refer :all]

(defn find-links [{:keys [source target group ts] :as link}]
  (let [colls {"replies" 3 "retweets" 4 "shares" 5}]
    (conj (apply concat
                 (pmap (fn [coll]
                        (apply concat
                               (pmap
                                (fn [{:keys [source target ts]}]
                                  (find-links {:source source
                                               :target target
