diff options
| -rw-r--r-- | rumba/model.py | 2 |
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]: |