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


          (:drained? status)
          ;; emit final completion barrier
          (periodic-barrier (assoc state :sealing? true :scheduled? false))

          (and scheduled? (> (System/nanoTime) next-barrier-time))
          (periodic-barrier (assoc state :sealing? false :scheduled? false))  

          (and (not scheduled?)
               (not (checkpointing? state status)))

          ;; 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)
