hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-06 10:31:39 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

[Streaming] Remove is_direct_call param (#10525)

Browse source
This commit is contained in:
Lixin Wei 2020-09-03 17:13:18 +08:00 • committed by GitHub
parent 553a93c5cc
commit d8ac4bc719
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
streaming/python/tests/test_direct_transfer.py
View file

@ -101,8 +101,8 @@ class Worker:
def test_queue(): def test_queue():
ray.init() ray.init()
writer = Worker._remote(is_direct_call=True) writer = Worker._remote()
reader = Worker._remote(is_direct_call=True) reader = Worker._remote()
channel_id_str = transfer.ChannelID.gen_random_id() channel_id_str = transfer.ChannelID.gen_random_id()
inits = [ inits = [
writer.init_writer.remote(channel_id_str, pickle.dumps(reader)), writer.init_writer.remote(channel_id_str, pickle.dumps(reader)),