Searched refs:_close_on_stop (Results 1 – 1 of 1) sorted by relevance
285 def _close_on_stop(self, sess, cancel_op, coord): member in QueueRunner346 ret_threads.append(threading.Thread(target=self._close_on_stop,