build_graph.clj

        root (-> (dp/poller-graph s)
                 (add-edge (fn [x]
                             (log/info (format "Finished an entry %s has body: %s"
					       (-> x :entry :link) (not (nil? (-> x :entry :body)))))))
                 zip/root graph-zip zip/down zip-down ; Move to feed-fetch-node
                 (add-edge (fn [{k :key b :body}]
                             (let [es (set (feeds/extract-entries b))]
                               (swap! fetched-feeds conj k)
                               (swap! extracted-entries set/union es)
                               (log/info (format "Added %d entries from %s." (count es) k))))))