Skip to content

Commit

Permalink
Fix __del__ in VectorEnv
Browse files Browse the repository at this point in the history
  • Loading branch information
tristandeleu committed Jun 2, 2019
1 parent d3bd3bb commit da71bd1
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 2 deletions.
4 changes: 3 additions & 1 deletion gym/vector/async_vector_env.py
Original file line number Diff line number Diff line change
Expand Up @@ -299,7 +299,9 @@ def _raise_if_errors(self):
raise exctype(value)

def __del__(self):
self.close(terminate=True)
if not self.closed:
self.close(terminate=True)
super(AsyncVectorEnv, self).__del__()


def _worker(index, env_fn, pipe, parent_pipe, shared_memory, error_queue):
Expand Down
4 changes: 3 additions & 1 deletion gym/vector/vector_env.py
Original file line number Diff line number Diff line change
Expand Up @@ -65,4 +65,6 @@ def close(self, **kwargs):
self.closed = True

def __del__(self):
self.close()
if not self.closed:
self.close()
super(VectorEnv, self).__del__()

0 comments on commit da71bd1

Please sign in to comment.