Add deprecation warning to dask_mpi.py
@@ -4,6 +4,7 @@ import click
from mpi4py import MPI
from tornado.ioloop import IOLoop
from tornado import gen
+from warnings import warn
from distributed import Scheduler, Nanny, Worker
from distributed.bokeh.worker import BokehWorker
@@ -98,6 +99,10 @@ def main(scheduler_file, interface, nthreads, local_directory, memory_limit,
def go():
check_python_3()
+ warn("The dask-mpi command line utility in the `distributed` "
+ "package is deprecated. "
+ "Please install the `dask-mpi` package instead. "
+ "More information is available at https://mpi.dask.org")
main()
