Function test_log_java_worker_logs

python/ray/tests/test_logging_java.py:27–51

(shutdown_only, capsys)

    reason="Does not work on Windows and OSX.",
)
def test_log_java_worker_logs(shutdown_only, capsys):
    with tempfile.TemporaryDirectory() as tmp_dir:
        print("using tmp_dir", tmp_dir)
        with open(os.path.join(tmp_dir, "MyClass.java"), "w") as f:
            f.write(_MY_CLASS_JAVA)
        subprocess.check_call(["javac", "MyClass.java"], cwd=tmp_dir)
        subprocess.check_call(["jar", "-cf", "myJar.jar", "MyClass.class"], cwd=tmp_dir)

        ray.init(
            job_config=ray.job_config.JobConfig(code_search_path=[tmp_dir]),
        )

        handle = java_actor_class("MyClass").remote()
        ray.get(handle.printToLog.remote("here's my random line!"))

        def check():
            out, err = capsys.readouterr()
            out += err
            with capsys.disabled():
                print(out)
            return "here's my random line!" in out

        wait_for_condition(check)

        ray.shutdown()


if __name__ == "__main__":