(self, session)
| 31 | self._num_finished_workers, 1, use_locking=True) |
| 32 | |
| 33 | def end(self, session): |
| 34 | session.run(self._finish_self) |
| 35 | num_finished_workers = session.run(self._num_finished_workers) |
| 36 | while num_finished_workers < self._num_workers: |
| 37 | tf.logging.info("%d workers have finished ...", |
| 38 | num_finished_workers) |
| 39 | time.sleep(1) |
| 40 | num_finished_workers = session.run(self._num_finished_workers) |
no outgoing calls
no test coverage detected