       (let [event (get-event state)
             ;; output recovery is only supported with onyx/n-peers set
             ;; as we can't currently scale slot recovery up and down
-            stored (res/recover-output event recover-coordinates)
-            _ (info (:onyx.core/log-prefix event) "Recover output pipeline checkpoint:" stored)]
+            stored (res/recover-output event recover-coordinates)]
+        (info (:onyx.core/log-prefix event) "Recover output pipeline checkpoint:" stored)
         (p/recover! pipeline (t/replica-version state) stored)))
     (if (p/synced? pipeline (t/epoch state))
       (-> state

      state)))

(defn poll-recover-output [state]
  (let [subscriber (m/subscriber (get-messenger state))
        _ (sub/poll! subscriber)]
    (if (and (sub/blocked? subscriber)
             (sub/recovered? subscriber))
      (-> state

              {:lifecycle :lifecycle/check-publisher-heartbeats
               :builder (fn [event] 
                          (let [timeout (event->pub-liveness event)] 
                            (fn [state] (advance (check-upstream-heartbeats state timeout)))))}
              {:lifecycle :lifecycle/seal-barriers?
               :builder (fn [_] input-function-seal-barriers?)}
              {:lifecycle :lifecycle/seal-barriers?
