def compute(i, n, task=None): import time yield task.sleep(n) raise StopIteration((i, task.location, time.asctime())) # result of 'compute' is current time # client (local) task submits computations