Add worker dashboard (#282)

* Add worker dashboard

xref #280 (comment)

test-kubernetes

* lint

Author: TomAugspurger

dask-gateway-server/dask_gateway_server/backends/kubernetes/controller.py

@@ -1048,6 +1048,8 @@ def get_worker_command(self, namespace, cluster_name, config):
             str(config.worker_memory_limit),
             "--scheduler-address",
             f"tls://{service_name}.{namespace}:8786",
+            "--dashboard-address",
+            ":8787",
         ]
 
     def get_env(self, namespace, cluster_name, config):

dask-gateway/dask_gateway/dask_cli.py

@@ -565,6 +565,12 @@ async def start_scheduler(
 worker_parser.add_argument(
     "--scheduler-address", default=None, help="The scheduler address"
 )
+worker_parser.add_argument(
+    "--dashboard-address",
+    type=str,
+    default=":0",
+    help="The address the dashboard should listen at. Defaults to `:0`",
+)
 
 
 async def start_worker(
@@ -576,6 +582,8 @@ async def start_worker(
     scheduler_address=None,
     local_directory=None,
     nanny=True,
+    dashboard=True,
+    dashboard_address=":0",
 ):
     loop = IOLoop.current()
 
@@ -592,6 +600,8 @@ async def start_worker(
         security=security,
         name=worker_name,
         local_directory=local_directory,
+        dashboard=dashboard,
+        dashboard_address=dashboard_address,
     )
 
     if nanny:
@@ -612,6 +622,7 @@ def worker(argv=None):
     nthreads = args.nthreads
     memory_limit = args.memory_limit
     scheduler_address = args.scheduler_address
+    dashboard_address = args.dashboard_address
 
     gateway = make_gateway_client()
     security = make_security()
@@ -623,7 +634,13 @@ def worker(argv=None):
 
     async def run():
         worker = await start_worker(
-            gateway, security, worker_name, nthreads, memory_limit, scheduler_address
+            gateway,
+            security,
+            worker_name,
+            nthreads,
+            memory_limit,
+            scheduler_address,
+            dashboard_address=dashboard_address,
         )
         await worker.finished()