   (sim/create-test sim-conn
                    linear-cluster-model
                    {:db/id (d/tempid :test)
-                    :test/duration (u/hours->msec 1)}))
+                    :test/duration 60000}))
 
 (def linear-cluster-sim
   (sim/create-sim sim-conn


(def out-queue (str (java.util.UUID/randomUUID)))

(def n-messages 2000)

(def batch-size 1320)



(sim/create-action-log sim-conn linear-cluster-sim)

(doseq [n (range 3)]
  (swap! cluster conj (onyx.api/start-peers conn 1 peer-opts)))

(def pruns
