 
           (:drained? status)
           ;; emit final completion barrier
-          (periodic-barrier (assoc state :sealing? true :scheduled? false))
+          (periodic-barrier (assoc state :sealing? true))
 
           (and scheduled? (> (System/nanoTime) next-barrier-time))
-          (periodic-barrier (assoc state :sealing? false :scheduled? false))  
+          (periodic-barrier state)  
 
           (and (not scheduled?)
                (not (checkpointing? state status)))

             :checkpointing? checkpoint?
             :checkpoint-epoch (if checkpoint? (m/epoch messenger) (:checkpoint-epoch state))
             :offering? true
             :write-version next-write-version
             :barrier-opts {:completed? (:sealing? state)
                            :checkpoint? checkpoint?}

          ;; Continue offering barriers until success
          (offer-barriers state) 

          (and sealing? (not (checkpointing? state status)))
          (complete-job state)

          (or completed? sealing?
              (not= (m/replica-version messenger) (:replica-version status))
              (not= (m/epoch messenger) (:min-epoch status)))
          (do
           (LockSupport/parkNanos coordinator-max-sleep-ns)
