# Close the previous connection
self.connection.close(code=1000, reason="Replaced by a new connection")
- log.debug("Connection opened for %s by %s" % (self, connection.builder))
+ log.debug("Connection opened for %s" % self)
# Store the connection
- self.backend.jobs.connections[self] = connection
+ self.backend.jobs.connections[self.uuid] = connection
def disconnected(self):
"""
log.debug("%s has disconnected" % self)
try:
- del self.backend.jobs.connections[self]
+ del self.backend.jobs.connections[self.uuid]
except IndexError:
pass
Easy access to the control connection to a builder
"""
try:
- return self.backend.jobs.connections[self]
+ return self.backend.jobs.connections[self.uuid]
except KeyError:
pass