1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
from func.overlord.client import Overlord
import func.jobthing as jobthing
import time
import sys
TEST_SLEEP = 5
EXTRA_SLEEP = 5
SLOW_COMMAND = 1
QUICK_COMMAND = 2
RAISES_EXCEPTION_COMMAND = 3
FAKE_COMMAND = 4
TESTS = [ SLOW_COMMAND, QUICK_COMMAND, RAISES_EXCEPTION_COMMAND, FAKE_COMMAND ]
def __tester(async,test):
if async:
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 = overlord.test.sleep(TEST_SLEEP)
elif test == QUICK_COMMAND:
print "TESTING a quick command"
job_id = overlord.test.add(1,2)
elif test == RAISES_EXCEPTION_COMMAND:
print "TESTING a command that deliberately raises an exception"
job_id = overlord.test.explode() # doesn't work yet
elif test == FAKE_COMMAND:
print "TESTING a command that does not exist"
job_id = overlord.test.does_not_exist(1,2) # ditto
print "======================================================"
print "job_id = %s" % job_id
while True:
status = overlord.job_status(job_id)
(code, results) = status
nowtime = time.time()
delta = int(nowtime - oldtime)
if nowtime > oldtime + TEST_SLEEP + EXTRA_SLEEP:
print "time expired, test failed"
return
if code == jobthing.JOB_ID_RUNNING:
print "task is still running, %s elapsed ..." % delta
elif code == jobthing.JOB_ID_PARTIAL:
print "task reports partial status, %s elapsed, results = %s" % (delta, results)
elif code == jobthing.JOB_ID_FINISHED:
print "(non-async) task complete, %s elapsed, results = %s" % (delta, results)
return
elif code == jobthing.JOB_ID_FINISHED:
print "(async) task complete, %s elapsed, results = %s" % (delta, results)
return
else:
print "job not found: %s, %s elapased" % (code, delta)
time.sleep(1)
else:
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)
print "======================================================="
print "Testing non-async call"
print __tester(False,-1)
|
