            ; give the peer a bit of time to write the chunks out and ack the batches,
            ; since we want to ensure that the batches aren't re-read on restart
            (Thread/sleep 7000)
-           (throw (ex-info "Restartable" {:restartable? true})))
+           (throw (ex-info "Restart me!" {})))
          {}))})
 
   (def compaction-finished? (atom false))

    [1442115900000 1442116199999 {37 1}]
    [1442115000000 1442115299999 {60 1}]})

(defn restartable? [e] 
  true)

(defrecord MonitoringStats
  [zookeeper-write-log-entry

         {:onyx/name :identity
          :onyx/fn :clojure.core/identity
          :onyx/group-by-key :age ;; irrelevant because only one peer
          :onyx/uniqueness-key :id
          :onyx/min-peers 1
          :onyx/max-peers 1
