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
|
from jobqueue.client import connect
DEBUG = True
# server = connect('http://reflectometry.org/queue')
server = connect("http://localhost:5000")
def checkqueue(pending=[], active=[], complete=[]):
qpending = server.jobs("PENDING")
qactive = server.jobs("ACTIVE")
qcomplete = server.jobs("COMPLETE")
if DEBUG:
print("pending", qpending, "active", qactive, "complete", qcomplete)
# assert pending == qpending
# assert active == qactive
# assert complete == qcomplete
long = {"service": "count", "data": 1000000, "name": "long count", "notify": "me"}
short = {"service": "count", "data": 200, "name": "short count", "notify": "me"}
fail1 = {"service": "count", "data": "string", "name": "short count", "notify": "me"}
fail2 = {"service": "noservice", "data": "string", "name": "short count", "notify": "me"}
job = server.submit(int)
print("submit", job)
# import sys; sys.exit()
checkqueue()
job2 = server.submit(short)
print("submit", job2)
result = server.wait(job["id"], pollrate=10, timeout=120)
print("result", result)
checkqueue()
print("fetch", server.info(job["id"]))
print("delete", server.delete(job["id"]))
checkqueue()
job3 = server.submit(fail1)
job4 = server.submit(fail2)
print("===incorrect service options")
result = server.wait(job3["id"], pollrate=1, timeout=120)
print(result["error"])
print(result["trace"])
print("===incorrect service")
result = server.wait(job4["id"], pollrate=1, timeout=120)
print(result["error"])
print(result["trace"])
|
