 
   (def in-calls
     {:lifecycle/before-task-start inject-in-ch})
+
+  (def identity-calls
+    {:lifecycle/handle-exception restartable?})
 
   (def out-calls
     {:lifecycle/before-task-start inject-out-ch})

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

(defn restartable? [e] 
  true)

(defrecord MonitoringStats
  [zookeeper-write-log-entry

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