Revision 99af08a4 snf-cyclades-app/synnefo/logic/callbacks.py
b/snf-cyclades-app/synnefo/logic/callbacks.py | ||
---|---|---|
105 | 105 |
network_id = utils.id_from_network_name(msg["network"]) |
106 | 106 |
network = Network.objects.select_for_update().get(id=network_id) |
107 | 107 |
backend = Backend.objects.get(clustername=msg['cluster']) |
108 |
backend_network = BackendNetwork.objects.get(network=network, |
|
109 |
backend=backend) |
|
110 |
func(backend_network, msg) |
|
108 |
bnet, new = BackendNetwork.objects.get_or_create(network=network, |
|
109 |
backend=backend) |
|
110 |
if new: |
|
111 |
log.info("Created missing BackendNetwork %s", bnet) |
|
112 |
func(bnet, msg) |
|
111 | 113 |
except Network.InvalidBackendIdError: |
112 | 114 |
log.debug("Ignoring msg for unknown network %s.", msg['network']) |
113 | 115 |
except Network.DoesNotExist: |
Also available in: Unified diff