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

          :lifecycle/calls ::in-calls}
         {:lifecycle/task :in
          :lifecycle/calls :onyx.plugin.core-async/reader-calls}
         {:lifecycle/task :out
          :lifecycle/calls ::out-calls}
         {:lifecycle/task :identity

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

(defn restartable? [event lifecycle lifecycle-name e]
  :restart)

(defrecord MonitoringStats
  [zookeeper-write-log-entry
