def join(self, builder, connection):
try:
- self.builders[builder].append(connection)
+ self.builders[builder.name].append(connection)
except KeyError:
- self.builders[builder] = [connection]
+ self.builders[builder.name] = [connection]
def leave(self, connection):
# Find and remove the connection
- for builder in self.builders.copy():
+ for name in self.builders.copy():
try:
- self.builders[builder].remove(connection)
+ self.builders[name].remove(connection)
except ValueError:
continue
- # Remove the builder if it has no connections left
- if not self.builders[builder]:
- del self.builders[builder]
-
async def submit_stats(self, builder, stats):
"""
Called when a builder sends new stats
"""
try:
- connections = self.builders[builder]
+ connections = self.builders[builder.name]
except KeyError:
return