                          (if v 
                            (recur (conj after-done v))
                            after-done)))]
-      (fact after-done => #{}))
-
+      (fact after-done => #{})
+      (fact @bad-values => #{}))
     (close! kill-ch)
-    (<!! mess-with-peers-ch)
-    (helper-env/remove-n-peers test-env 9))
-
+    #_(<!! mess-with-peers-ch))
   (finally 
     (component/stop test-env)))

(def incomplete 
  (atom #{}))

(def n-messages-total 100000)

(try

                                     (let [v (<!! out-chan)]
                                       (when (and v (not= v :done)) 
                                         (swap! incomplete disj v)
                                         (when (or (nil? (:a v))
                                                   (nil? (:b v)))
                                           (swap! bad-values conj v))
                                         (recur))))
        kill-ch (chan 1)
        mess-with-peers-ch (go-loop []
                                    (let [; average the the full circuit worth of timeouts
                                          chaos-kill-ms (rand-int (* 3 batch-timeout 2))
                                          [v ch] (alts!! [(timeout chaos-kill-ms) kill-ch])]
                                      (when-not (= ch kill-ch) 
                                        (try 
                                          (when-let [non-input-peers (->> (get (:allocations @(:replica test-env)) job-id)
