Removing asdfasdf.txt

This commit is contained in:
Mehrdad
2016-06-20 16:51:18 -07:00
parent 0f9ce8a856
commit f8ab525ef0
2 changed files with 0 additions and 25 deletions
-18
View File
@@ -123,24 +123,6 @@ class ObjStoreTest(unittest.TestCase):
services.cleanup()
class SchedulerTest(unittest.TestCase):
def testRemoteTask(self):
worker_path = os.path.join(os.path.dirname(os.path.abspath(__file__)), "test_worker.py")
[w] = services.start_singlenode_cluster(return_drivers=True, num_workers_per_objstore=1, worker_path=worker_path)
value_before = "test_string"
objref = w.submit_task("test_functions.print_string", [value_before])
time.sleep(0.2)
value_after = ray.pull(objref[0], w)
self.assertEqual(value_before, value_after)
time.sleep(0.1)
services.cleanup()
class WorkerTest(unittest.TestCase):
def testPushPull(self):
-7
View File
@@ -4,13 +4,6 @@ import numpy as np
# Test simple functionality
@ray.remote([str], [str])
def print_string(string):
print "called print_string with", string
f = open("asdfasdf.txt", "w")
f.write("successfully called print_string with argument {}.".format(string))
return string
@ray.remote([int, int], [int, int])
def handle_int(a, b):
return a + 1, b + 1