diff --git a/test/arrays_test.py b/test/arrays_test.py
index 41d64e742..5ab33c283 100644
--- a/test/arrays_test.py
+++ b/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")
diff --git a/test/microbenchmarks.py b/test/microbenchmarks.py
index 94c1b7d09..ce144c1ce 100644
--- a/test/microbenchmarks.py
+++ b/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
diff --git a/test/runtest.py b/test/runtest.py
index f9e125c17..67be6d6ca 100644
--- a/test/runtest.py
+++ b/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()
diff --git a/test/testrecv.py b/test/test_worker.py
similarity index 100%
rename from test/testrecv.py
rename to test/test_worker.py