         pq (:qvar-result (add-param-query! g :pq '[?s knows ?o]))
         jq (:qvar-result (add-join-query! g '[[?p author ?prj] [?prj type project] [?p type person]]))
         tq (:qvar-result (add-join-query! g '[[?p author ?prj] [?prj tag ?t]]))
-        ctx (f/async-execution-context {:graph g :timeout 10})
+        _ (run!
+           #(add-triple! g %)
+           '[[toxi author fabric]
+             [fabric type project]
+             [knows type symmetric-prop]
+             [knows domain person]
+             [author domain person]
+             [author range creative-work]
+             [parent sub-prop-of ancestor]
+             [ancestor type transitive-prop]
+             [ancestor domain person]
+             [ancestor range person]
+             ;;[noah knows toxi]
+             ])
+        ctx (f/async-execution-context {:graph g :timeout 100})
         ctx-chan (f/execute! ctx)]
     (go []
         (let [res (<! ctx-chan)]
           (warn :result res)
-          (warn (sort @@all))
-          (add-triple! g '[toxi parent noah])
-          (add-triple! g '[ingo parent toxi])
-          (add-triple! g '[geom type project])
-          (add-triple! g '[toxi author geom])
-          (add-triple! g '[toxi knows noah])
-          (add-triple! g '[geom tag clojure])
-          (add-triple! g '[fabric tag clojure])
+          (warn (sort @all))
+          (run!
+           #(f/signal! (add-triple! g %) f/async-vertex-signal)
+           '[[toxi parent noah]
+             [ingo parent toxi]
+             [geom type project]
+             [toxi author geom]
+             [toxi knows noah]
+             [geom tag clojure]
+             [fabric tag clojure]])
           (loop []
             (let [res (<! ctx-chan)]
               (warn :result res)
               (when (= :converged (:type res))
-                (warn (sort @@all))
-                (warn @@pq)
-                (warn @@jq)
-                (warn @@tq)
+                (warn (sort @all))
+                (warn @pq)
+                (warn @jq)
+                (warn @tq)
                 (f/stop! ctx)
                 (recur))))))
-    (mapv
-     #(add-triple! g %)
-     '[[toxi author fabric]
-       [fabric type project]
-       [knows type symmetric-prop]
-       [knows domain person]
-       [author domain person]
-       [author range creative-work]
-       [parent sub-prop-of ancestor]
-       [ancestor type transitive-prop]
-       [ancestor domain person]
-       [ancestor range person]
-       ;;[noah knows toxi]
-       ])
+
     {:g        g
      :ctx      ctx
      :all      all

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


        (f/add-edge! g v subj signal-triple :remove)
        (f/add-edge! g v pred signal-triple :remove)
        (f/add-edge! g v obj  signal-triple :remove)
        (swap! triples dissoc t)
        (f/remove-vertex! g v)
        v)
