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

Before Change

        .sink(sink_func)
    ctx.submit("HybridStreamTest")
    import time
    time.sleep(3)
    ray.shutdown()
    with open(sink_file, "r") as f:
        result = f.read()
        assert "a" in result

After Change

            return True
        return False

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

Instances