             [onyx.peer.pipeline-extensions :as p-ext]
             [onyx.peer.function :as function]
             [onyx.types :as t]
-            [onyx.static.default-vals :refer [defaults]]
+            [onyx.static.default-vals :refer [default-vals]]
 	    [clojure.core.async.impl.protocols :refer [closed?]]
             [onyx.log.zookeeper :as log-zk]
             [onyx.log.curator :as zk]

  [{:keys [onyx.core/task-map onyx.core/log onyx.core/peer-opts onyx.core/task-id onyx.core/job-id] :as event} lifecycle]
  (let [onyx-id (:onyx/tenancy-id peer-opts)
        ledgers-root-path (or (:bookkeeper/zookeeper-ledgers-root-path lifecycle)
                              (:onyx.bookkeeper/zk-ledgers-root-path defaults))
        zookeeper-addr (:bookkeeper/zookeeper-addr lifecycle)
        ;; FIXME, parameterize these in the lifecycle
        zookeeper-timeout 60000

  (validate-task-map! task-map BookKeeperOutput)
  (let [onyx-id (:onyx/tenancy-id peer-opts)
        ledgers-root-path (or (:bookkeeper/zookeeper-ledgers-root-path task-map)
                              (:onyx.bookkeeper/zk-ledgers-root-path default-vals))
        zookeeper-addr (:bookkeeper/zookeeper-addr task-map)
        ;; FIXME, parameterize these in the task-map
        zookeeper-timeout 60000
