import time import dask def elapsed(start): return str(time.time()-start)+"s" def computePart(size): part=0 for i in range(size): part=part+i return part def main(): size=40000000 numParts=4 parts=[] for i in range(numParts): part=dask.delayed(computePart)(size) parts.append(part) sumParts=dask.delayed(sum)(parts) start=time.time() sumParts.compute() computeTime=elapsed(start) print() print("=======================================") print("Compute time: "+computeTime) print("=======================================") print() if __name__=="__main__": start=time.time() main() wallClock=elapsed(start) print() print("----------------------------------------") print("wall clock time:"+wallClock) print("----------------------------------------") print()