From d8ac4bc7199ae8a108921a66a191733a0099d9f3 Mon Sep 17 00:00:00 2001 From: Lixin Wei Date: Thu, 3 Sep 2020 17:13:18 +0800 Subject: [PATCH] [Streaming] Remove is_direct_call param (#10525) --- streaming/python/tests/test_direct_transfer.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/streaming/python/tests/test_direct_transfer.py b/streaming/python/tests/test_direct_transfer.py index 309d6f054..5a8866d22 100644 --- a/streaming/python/tests/test_direct_transfer.py +++ b/streaming/python/tests/test_direct_transfer.py @@ -101,8 +101,8 @@ class Worker: def test_queue(): ray.init() - writer = Worker._remote(is_direct_call=True) - reader = Worker._remote(is_direct_call=True) + writer = Worker._remote() + reader = Worker._remote() channel_id_str = transfer.ChannelID.gen_random_id() inits = [ writer.init_writer.remote(channel_id_str, pickle.dumps(reader)),