Since most Dask examples are demonstrated using Jupyter notebooks, here’s an example of using Dask in a Python file or script. Notice how the Dask code must be in the
__main__ block or called from within a function.
import time from distributed import Client def adder(x): """ Some function to run in parallel using Dask. """ time.sleep(1) y = x + 1 return y def main(): """ Use the Dask distributed client to run a function in parallel. """ client = Client(n_workers=8) numbers = [3, 4, 5, 8, 12, 18, 25] futures =  for n in numbers: a = client.submit(adder, n) futures.append(a) results = client.gather(futures) print(results) client.close() if __name__ == '__main__': main()
🐍 Pythonic Programming
by Gavin Wiggins © 2022