unit test

risingwavelabs · Mar 10, 2023 · abf9e81 · abf9e81
1 parent a1725e7
commit abf9e81
Showing 1 changed file with 11 additions and 8 deletions.
diff --git a/src/meta/src/barrier/recovery.rs b/src/meta/src/barrier/recovery.rs
@@ -166,14 +166,17 @@ where
                 self.source_manager.clone(),
             ));
 
-            let mce = self
-                .hummock_manager
-                .get_current_version()
-                .await
-                .max_committed_epoch;
-
-            if mce != INVALID_EPOCH {
-                command_ctx.wait_epoch_commit(mce).await?;
+            #[cfg(not(test))]
+            {
+                let mce = self
+                    .hummock_manager
+                    .get_current_version()
+                    .await
+                    .max_committed_epoch;
+
+                if mce != INVALID_EPOCH {
+                    command_ctx.wait_epoch_commit(mce).await?;
+                }
             }
 
             let (barrier_complete_tx, mut barrier_complete_rx) =