   (onyx.api/shutdown-peer v-peer))
 
 (onyx.api/shutdown-env env)
+(fact true => true)
 


(onyx.api/kill-job peer-config j1)

(def replica-4
  (loop [replica replica-3]
    (let [position (<!! ch)
          entry (extensions/read-log-entry (:log env) position)
          new-replica (extensions/apply-log-entry entry replica)]
      (if-not (and (= (count (get (get (:allocations new-replica) j1) task-a)) 0)
                   (= (count (get (get (:allocations new-replica) j1) task-b)) 0)
                   (= (count (get (get (:allocations new-replica) j1) task-c)) 0)


(def peer-config
  (assoc (:peer-config config)
         :onyx/id onyx-id
         :onyx.peer/job-scheduler :onyx.job-scheduler/round-robin))

(def env (onyx.api/start-env env-config))

