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

move testrecv.py to test_worker.py

Browse source
This commit is contained in:
Philipp Moritz 2016-06-06 11:05:04 -07:00
parent 9dfe7c625e
commit dd8067def8
4 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
test/arrays_test.py
View file

@ -21,7 +21,7 @@ class ArraysSingleTest(unittest.TestCase):
def testMethods(self): def testMethods(self):
test_dir = os.path.dirname(os.path.abspath(__file__)) test_dir = os.path.dirname(os.path.abspath(__file__))
test_path = os.path.join(test_dir, "testrecv.py") test_path = os.path.join(test_dir, "test_worker.py")
services.start_singlenode_cluster(return_drivers=False, num_workers_per_objstore=1, worker_path=test_path) services.start_singlenode_cluster(return_drivers=False, num_workers_per_objstore=1, worker_path=test_path)
# test eye # test eye
@ -67,7 +67,7 @@ class ArraysDistTest(unittest.TestCase):
def testAssemble(self): def testAssemble(self):
test_dir = os.path.dirname(os.path.abspath(__file__)) test_dir = os.path.dirname(os.path.abspath(__file__))
test_path = os.path.join(test_dir, "testrecv.py") test_path = os.path.join(test_dir, "test_worker.py")
services.start_singlenode_cluster(return_drivers=False, num_workers_per_objstore=1, worker_path=test_path) services.start_singlenode_cluster(return_drivers=False, num_workers_per_objstore=1, worker_path=test_path)
a = ra.ones([da.BLOCK_SIZE, da.BLOCK_SIZE]) a = ra.ones([da.BLOCK_SIZE, da.BLOCK_SIZE])
@ -80,7 +80,7 @@ class ArraysDistTest(unittest.TestCase):
def testMethods(self): def testMethods(self):
test_dir = os.path.dirname(os.path.abspath(__file__)) test_dir = os.path.dirname(os.path.abspath(__file__))
test_path = os.path.join(test_dir, "testrecv.py") test_path = os.path.join(test_dir, "test_worker.py")
services.start_singlenode_cluster(return_drivers=False, num_objstores=2, num_workers_per_objstore=5, worker_path=test_path) services.start_singlenode_cluster(return_drivers=False, num_objstores=2, num_workers_per_objstore=5, worker_path=test_path)
x = da.zeros([9, 25, 51], "float") x = da.zeros([9, 25, 51], "float")

2
test/microbenchmarks.py
View file

@ -11,7 +11,7 @@ class MicroBenchmarkTest(unittest.TestCase):
def testTiming(self): def testTiming(self):
test_dir = os.path.dirname(os.path.abspath(__file__)) test_dir = os.path.dirname(os.path.abspath(__file__))
test_path = os.path.join(test_dir, "testrecv.py") test_path = os.path.join(test_dir, "test_worker.py")
services.start_singlenode_cluster(return_drivers=False, num_workers_per_objstore=3, worker_path=test_path) services.start_singlenode_cluster(return_drivers=False, num_workers_per_objstore=3, worker_path=test_path)
# measure the time required to submit a remote task to the scheduler # measure the time required to submit a remote task to the scheduler

10
test/runtest.py
View file

@ -126,7 +126,7 @@ class SchedulerTest(unittest.TestCase):
def testRemoteTask(self): def testRemoteTask(self):
test_dir = os.path.dirname(os.path.abspath(__file__)) test_dir = os.path.dirname(os.path.abspath(__file__))
test_path = os.path.join(test_dir, "testrecv.py") test_path = os.path.join(test_dir, "test_worker.py")
[w] = services.start_singlenode_cluster(return_drivers=True, num_workers_per_objstore=1, worker_path=test_path) [w] = services.start_singlenode_cluster(return_drivers=True, num_workers_per_objstore=1, worker_path=test_path)
value_before = "test_string" value_before = "test_string"
@ -176,7 +176,7 @@ class APITest(unittest.TestCase):
def testObjRefAliasing(self): def testObjRefAliasing(self):
test_dir = os.path.dirname(os.path.abspath(__file__)) test_dir = os.path.dirname(os.path.abspath(__file__))
test_path = os.path.join(test_dir, "testrecv.py") test_path = os.path.join(test_dir, "test_worker.py")
[w] = services.start_singlenode_cluster(return_drivers=True, num_workers_per_objstore=3, worker_path=test_path) [w] = services.start_singlenode_cluster(return_drivers=True, num_workers_per_objstore=3, worker_path=test_path)
objref = w.submit_task("test_functions.test_alias_f", []) objref = w.submit_task("test_functions.test_alias_f", [])
@ -190,7 +190,7 @@ class APITest(unittest.TestCase):
def testKeywordArgs(self): def testKeywordArgs(self):
test_dir = os.path.dirname(os.path.abspath(__file__)) test_dir = os.path.dirname(os.path.abspath(__file__))
test_path = os.path.join(test_dir, "testrecv.py") test_path = os.path.join(test_dir, "test_worker.py")
services.start_singlenode_cluster(return_drivers=False, num_workers_per_objstore=1, worker_path=test_path) services.start_singlenode_cluster(return_drivers=False, num_workers_per_objstore=1, worker_path=test_path)
x = test_functions.keyword_fct1(1) x = test_functions.keyword_fct1(1)
@ -228,7 +228,7 @@ class APITest(unittest.TestCase):
def testVariableNumberOfArgs(self): def testVariableNumberOfArgs(self):
test_dir = os.path.dirname(os.path.abspath(__file__)) test_dir = os.path.dirname(os.path.abspath(__file__))
test_path = os.path.join(test_dir, "testrecv.py") test_path = os.path.join(test_dir, "test_worker.py")
services.start_singlenode_cluster(return_drivers=False, num_workers_per_objstore=1, worker_path=test_path) services.start_singlenode_cluster(return_drivers=False, num_workers_per_objstore=1, worker_path=test_path)
x = test_functions.varargs_fct1(0, 1, 2) x = test_functions.varargs_fct1(0, 1, 2)
@ -245,7 +245,7 @@ class ReferenceCountingTest(unittest.TestCase):
def testDeallocation(self): def testDeallocation(self):
test_dir = os.path.dirname(os.path.abspath(__file__)) test_dir = os.path.dirname(os.path.abspath(__file__))
test_path = os.path.join(test_dir, "testrecv.py") test_path = os.path.join(test_dir, "test_worker.py")
services.start_singlenode_cluster(return_drivers=False, num_workers_per_objstore=3, worker_path=test_path) services.start_singlenode_cluster(return_drivers=False, num_workers_per_objstore=3, worker_path=test_path)
x = test_functions.test_alias_f() x = test_functions.test_alias_f()

0
test/testrecv.py → test/test_worker.py
View file