   (clean-up-broken-connections
    (fn []
      (let [node (str (flow-path prefix) "/" id)]
+       (decompress (:data (zk/data conn node)))))))
+
+(defmethod extensions/read-chunk [ZooKeeper :lifecycles]
+  [{:keys [conn opts prefix] :as log} kw id & _]
+  (clean-up-broken-connections
+   (fn []
+     (let [node (str (lifecycles-path prefix) "/" id)]
        (decompress (:data (zk/data conn node)))))))
 
 (defmethod extensions/read-chunk [ZooKeeper :task]


(defn flow-path [prefix]
  (str (prefix-path prefix) "/flow"))

(defn task-path [prefix]
  (str (prefix-path prefix) "/task"))

           bytes (compress chunk)]
       (zk/create conn node :persistent? true :data bytes)))))

(defmethod extensions/write-chunk [ZooKeeper :lifecycles]
  [{:keys [conn opts prefix] :as log} kw chunk id]
  (clean-up-broken-connections
   (fn []
     (let [node (str (lifecycles-path prefix) "/" id)
           bytes (compress chunk)]
       (zk/create conn node :persistent? true :data bytes)))))

(defmethod extensions/write-chunk [ZooKeeper :task]
  [{:keys [conn opts prefix] :as log} kw chunk id]
  (clean-up-broken-connections
