(self, worker)
| 138 | self._call_handlers(self.on.node_join, worker) |
| 139 | |
| 140 | def on_node_leave(self, worker): |
| 141 | debug('%s left', worker.hostname) |
| 142 | self._call_handlers(self.on.node_leave, worker) |
| 143 | |
| 144 | def on_node_lost(self, worker): |
| 145 | info('missed heartbeat from %s', worker.hostname) |