                     (when (<! notify-chan)
                       (reset! t0 (now))
                       (reset! active (sequence v-filter (vertices g)))
-                      (reset! enable #{})
+                      (reset! queue #{})
                       ;;(warn :rerun (count @active))
                       (recur 0 0))))))
           res-chan)))))

      IGraphExecutor
      (stop!
        [_]
        (remove-watch! g :add-vertex watch-id)
        (remove-watch! g :remove-vertex watch-id)
        (remove-watch! g :add-edge watch-id)
        (async/close! notify-chan))
      (notify!
        [_] (go (>! notify-chan true)) nil)

  []
  {:collect-thresh 0
   :signal-thresh  0
   ;;:signal-fn      parallel-signal-pass
   ;;:collect-fn     parallel-collect-pass
   ;;:scheduler      two-pass-scheduler
   :processor      eager-probabilistic-vertex-processor
   :scheduler      single-pass-scheduler
   :max-ops        1e6
   :threads        #?(:clj (inc (.availableProcessors (Runtime/getRuntime))) :cljs 1)})

