diff --git a/src/runtime/communication.rs b/src/runtime/communication.rs
index 9f077a6ac772e7f4bbd149f5f24f2c9d2dd5b2b7..dfe7ab443a16e4595f749618f13088706573a391 100644
--- a/src/runtime/communication.rs
+++ b/src/runtime/communication.rs
@@ -269,10 +269,11 @@ impl Connector {
             }
             let branch = NativeBranch { index, gotten: Default::default(), to_get };
             if let Some(existing) = branching_native.branches.insert(predicate, branch) {
-                // TODO
                 return Err(Se::IndistinguishableBatches([index, existing.index]));
             }
         }
+        // restore the invariant
+        comm.native_batches.push(Default::default());
         let decision = Self::sync_reach_decision(
             cu,
             comm,
@@ -353,7 +354,6 @@ impl Connector {
             }
         }
         log!(cu.logger, "Done translating native batches into branches");
-        comm.native_batches.push(Default::default());
 
         // run all proto components to their sync blocker
         log!(