Merge pull request #89 from amplab/test_worker

move testrecv.py to test_worker.py

test/arrays_test.py

@@ -21,7 +21,7 @@ class ArraysSingleTest(unittest.TestCase):
 
   def testMethods(self):
     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)
 
     # test eye
@@ -67,7 +67,7 @@ class ArraysDistTest(unittest.TestCase):
 
   def testAssemble(self):
     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)
 
     a = ra.ones([da.BLOCK_SIZE, da.BLOCK_SIZE])
@@ -80,7 +80,7 @@ class ArraysDistTest(unittest.TestCase):
 
   def testMethods(self):
     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)
 
     x = da.zeros([9, 25, 51], "float")

test/microbenchmarks.py

@@ -11,7 +11,7 @@ class MicroBenchmarkTest(unittest.TestCase):
 
   def testTiming(self):
     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)
 
     # measure the time required to submit a remote task to the scheduler

test/runtest.py

@@ -126,7 +126,7 @@ class SchedulerTest(unittest.TestCase):
 
   def testRemoteTask(self):
     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)
 
     value_before = "test_string"
@@ -176,7 +176,7 @@ class APITest(unittest.TestCase):
 
   def testObjRefAliasing(self):
     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)
 
     objref = w.submit_task("test_functions.test_alias_f", [])
@@ -190,7 +190,7 @@ class APITest(unittest.TestCase):
 
   def testKeywordArgs(self):
     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)
 
     x = test_functions.keyword_fct1(1)
@@ -228,7 +228,7 @@ class APITest(unittest.TestCase):
 
   def testVariableNumberOfArgs(self):
     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)
 
     x = test_functions.varargs_fct1(0, 1, 2)
@@ -245,7 +245,7 @@ class ReferenceCountingTest(unittest.TestCase):
 
   def testDeallocation(self):
     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)
 
     x = test_functions.test_alias_f()