Skip to content

Commit

Permalink
fix: clear pipeline before joining actors - fixes deadlock issue
Browse files Browse the repository at this point in the history
  • Loading branch information
EdanToledo committed Aug 27, 2024
1 parent 44a6422 commit d30e29a
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions stoix/systems/ppo/sebulba/ff_ppo.py
Original file line number Diff line number Diff line change
Expand Up @@ -807,6 +807,7 @@ def run_experiment(_config: DictConfig) -> float:

# Now we stop the actors and params sources
print(f"{Fore.MAGENTA}{Style.BRIGHT}Closing actors...{Style.RESET_ALL}")
pipeline.clear()
for actor in actor_threads:
# We clear the pipeline before stopping each actor thread
# since actors can be blocked on the pipeline
Expand Down

0 comments on commit d30e29a

Please sign in to comment.