(self)
| 332 | ) |
| 333 | |
| 334 | def create_server(self): |
| 335 | if self._server is None and self.ps_hosts and self.worker_hosts and not self.is_evaluator(): |
| 336 | # create server and join if it is a parameter server |
| 337 | self._server = tf.train.Server(self._cluster_spec, job_name=self.type, task_index=self._index) |
| 338 | if self.is_ps(): |
| 339 | self._server.join() |
| 340 | |
| 341 | def target(self): |
| 342 | if self._server is None: |
no test coverage detected