Dask_MPI initialize function execution never ends

Distributed
1

'm a new dask_mpi user, after installing dask_mpi via pip, I tried to run the basic example of the doc but the execution of the initialize never ends. How can I solve this problem? I’am using:

tornado==6.1

mpi4py==3.0.3

distributed==2022.4.0

dask==2022.4.0

dask-mpi==2022.4.0

The code:

   from dask_mpi import initialize
   initialize()
   from distributed import Client
   client = Client()

I tried to execute the script by:

python3 test_daksmpi.py

Output:

2022-08-26 16:08:22,160 - distributed.scheduler - INFO - Clear task state

2022-08-26 16:08:22,161 - distributed.scheduler - INFO - Scheduler at: tcp://134.206.210.148:46831

2022-08-26 16:08:22,161 - distributed.scheduler - INFO - dashboard at: :8787

2

Hi @ahmed, welcome here!

Maybe your post lacks some information: just to confirm, are you in some sort of HPC Center with a job queuing system? Are your running mpirun run command in some batch script as in the example of the dask-mpi documentation?

mpirun -np 4 python my_client_script.py
1 Like