hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-06 10:31:39 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

[tune] Fix TB Memory Leak (#5629)

Browse source
This commit is contained in:
Richard Liaw 2019-09-03 23:44:12 -07:00 • committed by Philipp Moritz
parent 6ab5714465
commit ad96d3c4fb
1 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
python/ray/tune/logger.py
View file

@ -144,9 +144,9 @@ def tf2_compat_logger(config, logdir):
else:
import tensorflow as tf
use_tf2_api = (distutils.version.LooseVersion(tf.__version__) >=
distutils.version.LooseVersion("1.14.0"))
distutils.version.LooseVersion("2.0.0"))
if use_tf2_api:
tf = tf.compat.v2 # setting this for 1.14
tf = tf.compat.v2 # setting this for TF2.0
return TF2Logger(config, logdir)
else:
return TFLogger(config, logdir)
@ -154,11 +154,13 @@ def tf2_compat_logger(config, logdir):
class TF2Logger(Logger):
def _init(self):
from tensorflow.python.eager import context
self._context = context
self._file_writer = tf.summary.create_file_writer(self.logdir)
def on_result(self, result):
with tf.device("/CPU:0"):
with self._file_writer.as_default():
with tf.device("/CPU:0"), self._context.eager_mode():
with tf.summary.record_if(True), self._file_writer.as_default():
step = result.get(
TIMESTEPS_TOTAL) or result[TRAINING_ITERATION]
@ -197,10 +199,8 @@ def to_tf_values(result, path):
class TFLogger(Logger):
def _init(self):
logger.info(
"Initializing TFLogger instead of TF2Logger. We recommend "
"migrating to TF2.0. This class will be removed in the future.")
self._file_writer = tf.summary.FileWriter(self.logdir)
logger.info("Initializing TFLogger instead of TF2Logger.")
self._file_writer = tf.compat.v1.summary.FileWriter(self.logdir)
def on_result(self, result):
tmp = result.copy()