Skip to content

Commit

Permalink
delete one repeat and check PEP8
Browse files Browse the repository at this point in the history
Signed-off-by: Jieru Hong <[email protected]>
  • Loading branch information
Jieru Hong committed Sep 4, 2019
1 parent 5330a31 commit 8e4e0c6
Showing 1 changed file with 4 additions and 9 deletions.
13 changes: 4 additions & 9 deletions pyzoo/test/zoo/ray/integration/test_multi.py
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,8 @@
from zoo.ray.util.raycontext import RayContext

np.random.seed(1337) # for reproducibility


@ray.remote
class TestRay():
def hostname(self):
Expand All @@ -43,8 +45,8 @@ def hostname(self):
driver_cores=4,
extra_executor_memory_for_ray="30g")
ray_ctx = RayContext(sc=sc, object_store_memory="2g")
#sc = init_spark_on_local(cores=node_num)
#ray_ctx = RayContext(sc=sc, object_store_memory="1g")
# sc = init_spark_on_local(cores=node_num)
# ray_ctx = RayContext(sc=sc, object_store_memory="1g")
ray_ctx.init()
actors = [TestRay.remote() for i in range(0, node_num)]
print([ray.get(actor.hostname.remote()) for actor in actors])
Expand All @@ -58,13 +60,6 @@ def hostname(self):
actors = [TestRay.remote() for i in range(0, node_num)]
print([ray.get(actor.hostname.remote()) for actor in actors])
ray_ctx.stop()
print("________________________second time done!________________")
time.sleep(2)
ray_ctx = RayContext(sc=sc, object_store_memory="1g")
ray_ctx.init()
actors = [TestRay.remote() for i in range(0, node_num)]
print([ray.get(actor.hostname.remote()) for actor in actors])
ray_ctx.stop()

sc.stop()
time.sleep(3)
Expand Down

0 comments on commit 8e4e0c6

Please sign in to comment.