                                (try
                                  (assoc op 
                                         :type :ok 
-                                        :value (mapv read-ledger-entries (get-written-ledgers onyx-client job-data onyx-id)))
+                                        ;; FIXME: mapcatting everything together for now
+                                        :value (mapv read-ledger-entries 
+                                                     (mapcat (fn [job-data] 
+                                                               (get-written-ledgers onyx-client job-data onyx-id))
+                                                             @jobs-data)))
                                  (catch Throwable t
                                    (assoc op :type :info :value t))))
 

  (teardown! [_ test]
    (.close client)))

(defn write-log-client [job-data ledger-handles ledger-ids]
  (->WriteLogClient nil job-data ledger-handles nil ledger-ids nil))

;; Not actually used for anything currently
(defrecord OnyxModel []

  []
  (gen/clients (gen/once {:type :invoke :f :close-ledgers-await-completion})))

(defn submit-job-gen [n-jobs]
  (->> (range n-jobs)
       (map (fn [n] 
              {:type :invoke 
               :f :submit-job 
               :job-num n
               :n-jobs n-jobs
               :params {:batch-size 1}}))
       gen/seq))

(def os
  (reify os/OS
    (setup! [_ test node]
