                         :onyx/fn :onyx-peers.functions.functions/add-job-num
                         :jepsen/job-num job-num
                         :onyx/params [:jepsen/job-num]
-                        :onyx/restart-pred-fn :onyx-peers.functions.functions/restartable?
                         :onyx/type :function
                         :onyx/batch-size batch-size}]
              :lifecycles [{:lifecycle/task :persist
+                           :lifecycle/calls ::restart-calls}
+                          {:lifecycle/task :identity-log
+                           :lifecycle/calls ::restart-calls}
+                          {:lifecycle/task :persist
                            :lifecycle/calls :onyx.plugin.bookkeeper/write-ledger-calls}]
              :workflow [[:identity-log :persist]]
              :task-scheduler :onyx.task-scheduler/balanced}] 

                        :onyx/plugin :onyx.plugin.bookkeeper/write-ledger
                        :onyx/type :output
                        :onyx/medium :bookkeeper
                        :onyx/restart-pred-fn :onyx-peers.functions.functions/restartable?
                        :bookkeeper/serializer-fn :onyx.compression.nippy/zookeeper-compress
                        :bookkeeper/password-bytes password
                        :bookkeeper/ensemble-size 3

                         :bookkeeper/deserializer-fn :onyx.compression.nippy/zookeeper-decompress
                         :bookkeeper/password-bytes password 
                         :bookkeeper/no-recovery? true
                         :onyx/max-peers 1
                         :onyx/batch-size batch-size
                         :onyx/doc "Reads a sequence from a BookKeeper ledger"})
