 
   (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})

         {: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 :identity
          :lifecycle/calls ::identity-calls}
         {:lifecycle/task :out
          :lifecycle/calls ::out-calls}
         {:lifecycle/task :identity
