This ended up being a problem after all

This commit is contained in:
Joseph Hall 2016-08-28 20:48:00 -06:00
parent 4aefe13306
commit a33cbac141

View File

@ -380,9 +380,8 @@ class AsyncZeroMQPubChannel(salt.transport.mixins.auth.AESPubClientMixin, salt.t
def connect(self):
if not self.auth.authenticated:
yield self.auth.authenticate()
if self.opts.get('detect_mode', False) is False:
self.publish_port = self.auth.creds['publish_port']
self._socket.connect(self.master_pub)
self.publish_port = self.auth.creds['publish_port']
self._socket.connect(self.master_pub)
@property
def master_pub(self):