        (sort-by second >)
        (take 50))
 
+
+  (->> @full-summaries
+       (pmap analyze-hashtags)
+       )
+
   )

                            (t/interval (-> loc zip/node :source :ts) pub-time))]
           (conj delays (t/in-seconds post-delay)))
         delays)
       (zip/next loc)))))




(def full-summaries
    (->> (mc/find-maps @db "publications" {:user {$in (keys suids)}})
         (pmap (comp full-reaction-tree :_id))
         future))


