           ;; Continue offering barriers until success
           (offer-barriers state) 
 
-          completed?
-          (do
-           (LockSupport/parkNanos coordinator-max-sleep-ns)
-           state)
-
-          sealing?
-          (if (checkpointing? state status)
-            (do
-             (LockSupport/parkNanos coordinator-max-sleep-ns)
-             state) 
-            (complete-job state))
-
-          (or (not= (m/replica-version messenger) (:replica-version status))
+          (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)

             :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?}


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

          (and scheduled? (> (System/nanoTime) next-barrier-time))
          (periodic-barrier state)  

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