ipyparallel_local_cluster_parallel_map_quickstart.py

1import ipyparallel as ipp
2
3# Connect to the local cluster
4cluster = ipp.Cluster()
5with cluster as rc:
6    # Get a view on the engines
7    view = rc.load_balanced_view()
8    
9    # Submit a simple task to all engines
10    def f(x):
11        return x * x
12
13    # Execute the function in parallel
14    results = view.map_sync(f, range(10))
15    print(f"Results: {results}")