diff options
| author | Marco Capitani <m.capitani@nextworks.it> | 2017-09-26 17:20:48 +0200 |
|---|---|---|
| committer | Marco Capitani <m.capitani@nextworks.it> | 2017-09-26 17:20:48 +0200 |
| commit | bc8f4bd7e45affd6e3d74562a0511a634d0d92cd (patch) | |
| tree | a7f18bcc9a2a39507dd89f1ec5b55e807ef11c96 | |
| parent | 257ac48837755f2d48e2b99e9462da9fa17c05d7 (diff) | |
| download | rumba-bc8f4bd7e45affd6e3d74562a0511a634d0d92cd.tar.gz rumba-bc8f4bd7e45affd6e3d74562a0511a634d0d92cd.zip | |
Model: add check for disconnected dif
| -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]: |