cd6936e60bdd984b50877d810d317e33b889c3c5,rllib/tests/test_env_with_subprocess.py,,,#,22

Before Change

            },
        },
    })
    time.sleep(10.0)
    // Check whether processes are still running or Env has not cleaned up
    // the given tmp files.
    leaked = leaked_processes()
    assert not leaked, "LEAKED PROCESSES: {}".format(leaked)

After Change

    wait_for_condition(lambda: not os.path.exists(tmp1), timeout=30)
    wait_for_condition(lambda: not os.path.exists(tmp2), timeout=30)
    wait_for_condition(lambda: not os.path.exists(tmp3), timeout=30)
    wait_for_condition(lambda: not os.path.exists(tmp4), timeout=30)
    print("OK")

Instances