Bug: only agents who host wfas can run them; and only the wfas mapped to them.

networking_capnet/plugins/ml2/drivers/capnet/capnet_neutron_agent.py

@@ -1540,12 +1540,15 @@ class CapnetNeutronAgent(service.Service):
             pass
         
         # Fire off any workflow agents that need to be running...
-        for binding in bindings:
-            if 'wfagent' in binding and not binding['wfagent'] is None \
-              and 'port' in binding and not binding['port'] is None:
-                LOG.debug("ensure_running(%s)" % (str(binding),))
-                self.wfagent_manager.ensure_running(binding['wfagent'],
-                                                    binding['port'])
+        if self.hosts_workflow_apps:
+            for binding in bindings:
+                if 'wfagent' in binding and not binding['wfagent'] is None \
+                  and 'port' in binding and not binding['port'] is None \
+                  and 'host' in binding and binding['host'] == cfg.CONF.host:
+                    LOG.debug("ensure_running(%s)" % (str(binding),))
+                    self.wfagent_manager.ensure_running(binding['wfagent'],
+                                                        binding['port'])
+                    pass
                 pass
             pass