3645a05644da90a694e613f4a1c0cc17e5f23ffc,streaming/python/tests/test_hybrid_stream.py,,test_hybrid_stream,#,22

Before Change

    import time
    time.sleep(3)
    ray.shutdown()
    with open(sink_file, "r") as f:
        result = f.read()
        assert "a" in result
        assert "b" not in result
        assert "c" in result


if __name__ == "__main__":
    test_hybrid_stream()

After Change

            return True
        return False

    wait_for_condition(check_succeed, timeout=60, retry_interval_ms=1000)
    print("Execution succeed")
    ray.shutdown()

Instances