aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--rumba/model.py2
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]: