task2.py
44 lines
| 871 B
| text/x-python
|
PythonLexer
Brian E Granger
|
r1337 | #!/usr/bin/env python | ||
# encoding: utf-8 | ||||
Brian E Granger
|
r1338 | from IPython.kernel import client | ||
Brian E Granger
|
r1337 | import time | ||
tc = client.TaskClient() | ||||
mec = client.MultiEngineClient() | ||||
mec.execute('import time') | ||||
for i in range(24): | ||||
Brian E Granger
|
r1395 | tc.run(client.StringTask('time.sleep(1)')) | ||
Brian E Granger
|
r1337 | |||
for i in range(6): | ||||
time.sleep(1.0) | ||||
print "Queue status (vebose=False)" | ||||
print tc.queue_status() | ||||
for i in range(24): | ||||
Brian E Granger
|
r1395 | tc.run(client.StringTask('time.sleep(1)')) | ||
Brian E Granger
|
r1337 | |||
for i in range(6): | ||||
time.sleep(1.0) | ||||
print "Queue status (vebose=True)" | ||||
print tc.queue_status(True) | ||||
for i in range(12): | ||||
Brian E Granger
|
r1395 | tc.run(client.StringTask('time.sleep(2)')) | ||
Brian E Granger
|
r1337 | |||
print "Queue status (vebose=True)" | ||||
print tc.queue_status(True) | ||||
qs = tc.queue_status(True) | ||||
sched = qs['scheduled'] | ||||
for tid in sched[-4:]: | ||||
tc.abort(tid) | ||||
for i in range(6): | ||||
time.sleep(1.0) | ||||
print "Queue status (vebose=True)" | ||||
print tc.queue_status(True) | ||||