(self)
| 235 | logger.info("Distributed training on cluster:\n" + str(server.server_def.cluster)) |
| 236 | |
| 237 | def join(self): |
| 238 | logger.info("Calling server.join() on {}:{}".format(self.job_name, self.server.server_def.task_index)) |
| 239 | logger.info("Kill me with 'kill {}'".format(os.getpid())) |
| 240 | self.server.join() # this function will never return tensorflow#4713 |
| 241 | raise RuntimeError("This is a bug. Server.join() for should never return!") |
| 242 | |
| 243 | @HIDE_DOC |
| 244 | def initialize(self, session_creator, session_init): |