             [taoensso.timbre :refer [fatal info]]
             [onyx.api]))
 
+(def input
+  (vec (range 6)))
+
 (deftest ^:test-jepsen-tests basic-test
   (let [id (java.util.UUID/randomUUID)
         config (load-config)

        test "basic-clojure-test"
        version "dummy-version"
        test-setup {:job-params {:batch-size 1}
                    :nemesis :na
                    :time-limit 800 ; unused in this test
                    :awake-mean 200 ; unused in this test

                    :n-peers 3}
        fake-clients 5
        n-peers-total (* fake-clients (:n-peers test-setup))
        events (into (mapv (fn [v]
                             {:type :invoke :f :add :value v})
                           input)
                     [{:type :invoke 
                       :f :submit-job 
                       :job-type (:job-type test-setup) 
                       :job-num 0 
                       :n-jobs (:n-jobs test-setup) 
                       :params (:job-params test-setup)}
                      {:type :invoke :f :close-ledgers-await-completion}
                      {:type :invoke :f :read-ledgers :task :persist}
                      {:type :invoke :f :read-peer-log :timeout 1000}])
        {:keys [client checker model generator] :as basic-test} 
        (onyx-test/jepsen-test env-config peer-config test-setup test version (gen/seq events))]
    (with-test-env [test-env [n-peers-total env-config peer-config]]
