Running your First Distributed Python Application

step_1.py

import ray
import time
from datetime import datetime as dt

@ray.remote
def adder(input_value):
    time.sleep(1)
    return input_value+1

if __name__ == '__main__':
    ray.init()
    values = range(10)
    start = dt.now()
    new_values = [adder.remote(x) for x in values]
    return_value = ray.get(new_values)
    end = dt.now()
    print("Return Value: {}".format(return_value))
    print("Elapsed Time: {}".format((end-start).total_seconds()))