Commit 4665d5f1 authored by Shashank Suhas's avatar Shashank Suhas

repeat v1 compat

parent 39bf1e59
...@@ -11,7 +11,7 @@ import numpy as np ...@@ -11,7 +11,7 @@ import numpy as np
import os import os
import sys import sys
import uuid import uuid
import tensorflow as tf import tensorflow.compat.v1 as tf
from six.moves import queue from six.moves import queue
from concurrent import futures from concurrent import futures
CancelledError = futures.CancelledError CancelledError = futures.CancelledError
...@@ -27,6 +27,8 @@ from atari_wrapper import FireResetEnv, FrameStack, LimitLength, MapState ...@@ -27,6 +27,8 @@ from atari_wrapper import FireResetEnv, FrameStack, LimitLength, MapState
from common import Evaluator, eval_model_multithread, play_n_episodes from common import Evaluator, eval_model_multithread, play_n_episodes
from simulator import SimulatorMaster, SimulatorProcess, TransitionExperience from simulator import SimulatorMaster, SimulatorProcess, TransitionExperience
tf.disable_eager_execution()
IMAGE_SIZE = (84, 84) IMAGE_SIZE = (84, 84)
FRAME_HISTORY = 4 FRAME_HISTORY = 4
GAMMA = 0.99 GAMMA = 0.99
...@@ -169,6 +171,7 @@ class MySimulatorMaster(SimulatorMaster, Callback): ...@@ -169,6 +171,7 @@ class MySimulatorMaster(SimulatorMaster, Callback):
""" """
Launch forward prediction for the new state given by some client. Launch forward prediction for the new state given by some client.
""" """
print(state)
def cb(outputs): def cb(outputs):
try: try:
distrib, value = outputs.result() distrib, value = outputs.result()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment