##// END OF EJS Templates
Test for #2727 (%run -m doesn't support relative imports)...
Test for #2727 (%run -m doesn't support relative imports) test_run_submodule_with_relative_import fails.

File last commit:

r9190:20a102a5
r9994:ced51b9d
Show More
task2.py
50 lines | 924 B | text/x-python | PythonLexer
#!/usr/bin/env python
# encoding: utf-8
from IPython.parallel import Client
import time
import sys
flush = sys.stdout.flush
rc = Client()
v = rc.load_balanced_view()
mux = rc[:]
for i in range(24):
v.apply(time.sleep, 1)
for i in range(6):
time.sleep(1.0)
print("Queue status (vebose=False)")
print(v.queue_status(verbose=False))
flush()
for i in range(24):
v.apply(time.sleep, 1)
for i in range(6):
time.sleep(1.0)
print("Queue status (vebose=True)")
print(v.queue_status(verbose=True))
flush()
for i in range(12):
v.apply(time.sleep, 2)
print("Queue status (vebose=True)")
print(v.queue_status(verbose=True))
flush()
# qs = v.queue_status(verbose=True)
# queued = qs['scheduled']
for msg_id in v.history[-4:]:
v.abort(msg_id)
for i in range(6):
time.sleep(1.0)
print("Queue status (vebose=True)")
print(v.queue_status(verbose=True))
flush()