 
 (sim/create-action-log sim-conn linear-cluster-sim)
 
-(time (mapv (fn [prun] @(:runner prun))
-            (->> #(sim/run-sim-process sim-uri (:db/id linear-cluster-sim))
-                 (repeatedly (:sim/processCount linear-cluster-sim))
-                 (into []))))
+(def pruns
+  (->> #(sim/run-sim-process sim-uri (:db/id linear-cluster-sim))
+       (repeatedly (:sim/processCount linear-cluster-sim))
+       (into [])))
 
 (testing "All tasks complete"
   (loop []

    :model/type :model.type/linear-cluster
    :model/n-peers 5
    :model/peek-peers 10
    :model/peer-rate 200
    :model/mean-ack-time 250
    :model/mean-completion-time 500}])


      (when-not (= result (* n-jobs tasks-per-job))
        (recur)))))

(doseq [prun pruns] (future-cancel (:runner prun)))

(def sim-db (d/db sim-conn))

(def result-db (d/db (:conn log)))
