 (defn add-query-filter!
   [g q-vertex flt]
   (let [fv (f/add-vertex!
-            g (delay nil)
+            g nil ;; FIXME delay
             {::f/collect-fn
              (f/collect-pure
               (fn [_ incoming]
-                (delay (sequence (comp (mapcat deref) (filter flt)) incoming))))})]
+                ;; FIXME delay
+                ;;(delay (sequence (comp (mapcat deref) (filter flt)) incoming))
+                (sequence (comp (mapcat identity) (filter flt)) incoming)
+                ))})]
     (f/add-edge! g q-vertex fv f/signal-forward nil)
     fv))
 

     :num-projects num-projects
     :num-types num-types
     }))

           {::f/collect-fn
            (f/collect-pure
             (fn [val in]
               (debug :updated-result (pr-str (peek in))) ;; FIXME delay @
               (count (peek in))))})]
    (f/add-edge! g src v f/signal-forward nil)
    v))

;; #?(:clj (taoensso.timbre/set-level! :warn))

#?(:clj
   (defn triple-logger
