diff options
Diffstat (limited to 'test/async_test.py')
| -rw-r--r-- | test/async_test.py | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/test/async_test.py b/test/async_test.py index 04f6fd5..8e6961d 100644 --- a/test/async_test.py +++ b/test/async_test.py @@ -1,4 +1,4 @@ -from func.overlord.client import Client +from func.overlord.client import Overlord import func.jobthing as jobthing import time import sys @@ -14,28 +14,28 @@ TESTS = [ SLOW_COMMAND, QUICK_COMMAND, RAISES_EXCEPTION_COMMAND, FAKE_COMMAND ] def __tester(async,test): if async: - client = Client("*",nforks=10,async=True) + overlord= Overlord("*",nforks=10,async=True) oldtime = time.time() job_id = -411 print "======================================================" if test == SLOW_COMMAND: print "TESTING command that sleeps %s seconds" % TEST_SLEEP - job_id = client.test.sleep(TEST_SLEEP) + job_id = overlord.test.sleep(TEST_SLEEP) elif test == QUICK_COMMAND: print "TESTING a quick command" - job_id = client.test.add(1,2) + job_id = overlord.test.add(1,2) elif test == RAISES_EXCEPTION_COMMAND: print "TESTING a command that deliberately raises an exception" - job_id = client.test.explode() # doesn't work yet + job_id = overlord.test.explode() # doesn't work yet elif test == FAKE_COMMAND: print "TESTING a command that does not exist" - job_id = client.test.does_not_exist(1,2) # ditto + job_id = overlord.test.does_not_exist(1,2) # ditto print "======================================================" print "job_id = %s" % job_id while True: - status = client.job_status(job_id) + status = overlord.job_status(job_id) (code, results) = status nowtime = time.time() delta = int(nowtime - oldtime) @@ -56,9 +56,9 @@ def __tester(async,test): print "job not found: %s, %s elapased" % (code, delta) time.sleep(1) else: - print Client("*",nforks=10,async=False).test.sleep(5) - print Client("*",nforks=10,async=False).test.bork(5) - print Client("*",nforks=1,async=False).test.bork(5) + print Overlord("*",nforks=10,async=False).test.sleep(5) + print Overlord("*",nforks=10,async=False).test.bork(5) + print Overlord("*",nforks=1,async=False).test.bork(5) for t in TESTS: __tester(True,t) |