AttributeError: PyProcessDmLab object has no attribute b'initial'

[alex-petrenko]

I am trying to run the single-level experiment as instructed in Readme:

python experiment.py --num_actors=48 --batch_size=32

But right after all the 48 actors are created the script crashes with the following stacktrace:

  File "/home/apetrenk/miniconda3/envs/doom-impala/lib/python3.7/site-packages/tensorflow/python/ops/script_ops.py", line 209, in __call__
    ret = func(*args)                                          
                                                                                                                                                
  File "/home/apetrenk/all/projects/doom/impala/scalable_agent/py_process.py", line 87, in py_call
    raise result                                                                                                                                   
                                                 
AttributeError: 'PyProcessDmLab' object has no attribute 'b'initial''                                                                        
                                                             
                                                                                                                                                            
         [[node flow_environment_initial_3/initial (defined at /home/apetrenk/all/projects/doom/impala/scalable_agent/py_process.py:97) ]]

Looks like for some reason the byte-literal is used instead of a string for the method name.

[taitoushiyun]

I found the same problem. it seems that the tf.py_fun function in py_process.py changes the args when wrapping the python function py_call to a tensorflow op.
result = tf.py_func(py_call, (name,) + tuple(args), flat_dtypes, name=name)
I wonder if it's a bug or i did something wrong with the dependencies.

[junjungoal]

I fix this as follows

      def py_call(*args):
        args = (args[0].decode('utf-8'), *args[1:]) # insert this
        try:
          self._out.send(args)
          result = self._out.recv()
          if isinstance(result, Exception):
            raise result
          if result is not None:
            return result
        except Exception as e:
          if isinstance(e, IOError):
            raise StopIteration()  # Clean exit.
          else:
            raise

I hope this will help you.

[taitoushiyun]

@junjungoal thank you. I will have a try