1 files changed, 2 insertions, 0 deletions
diff --git a/rumba/model.py b/rumba/model.py
index bb7d213..a223fb4 100644
--- a/rumba/model.py
+++ b/rumba/model.py
@@ -694,6 +694,8 @@ class Experiment:
                             self.dt_flows[-1].append({'src': enrollee,
                                                       'dst': enroller})
                         frontier.add(edge[0])
+            if len(dif.members) != len(enrolled):
+                raise Exception("Disconnected DIF found: %s" % (dif,))
 
             # In case of a full mesh enrollment or dt flows
             for cur in dif_graphs[dif]: