helloworld.py

import random
import time

from dask.distributed import Client


def inc(x: int) -> int:
    time.sleep(random.randrange(1, 2, 1))
    return x + 1


def double(x: int) -> int:
    time.sleep(random.randrange(1, 2, 1))
    return 2 * x


def add(x: int, y: int) -> int:
    time.sleep(random.randrange(1, 2, 1))
    return x + y


def dont_exit():
    while True:
        time.sleep(1)
        print("done waiting exit....")


if __name__ == '__main__':

    client = Client(threads_per_worker=4, n_workers=1)

    zs = []
    for i in range(10):
        x = client.submit(inc, i)  # x = inc(i)
        y = client.submit(double, x)  # y = inc(x)
        z = client.submit(add, x, y)  # z = inc(y)
        zs.append(z)

    total = client.submit(sum, zs)

    print("Total = {}".format(total.result()))

    dont_exit()