Merge pull request #79 from jacobtomlinson/optional_scheduler_ip

Only add scheduler_ip to opts if it has been set

Author: jacobtomlinson

dask_mpi/cli.py

@@ -131,7 +131,6 @@ async def run_worker():
                 )
                 WorkerType = Worker
             opts = {
-                "scheduler_ip": scheduler_address,
                 "interface": interface,
                 "protocol": protocol,
                 "nthreads": nthreads,
@@ -141,6 +140,8 @@ async def run_worker():
                 "scheduler_file": scheduler_file,
                 **worker_options,
             }
+            if scheduler_address:
+                opts["scheduler_ip"] = scheduler_address
             async with WorkerType(**opts) as worker:
                 await worker.finished()