class StatsHandler(base.BaseHandler, tornado.websocket.WebSocketHandler):
# No authentication required
async def open(self, name):
- builder = self.backend.builders.get_by_name(name)
+ builder = await self.backend.builders.get_by_name(name)
if not builder:
raise tornado.web.HTTPError(404, "Could not find builder %s" % name)
self.backend.builders.stats.join(builder=builder, connection=self)
# Initially send the stats that we currently have
- if builder.stats:
- await self.submit_stats(builder.stats)
+ stats = await builder.get_stats()
+ if stats:
+ await self.submit_stats(stats)
def on_close(self):
self.backend.builders.stats.leave(self)