Add HTML Repr for ProcessInterface Class and all its subclasses

distributed/deploy/spec.py

@@ -99,6 +99,52 @@ async def finished(self):
     def __repr__(self):
         return f"<{type(self).__name__}: status={self.status}>"
 
+    def _repr_html_(self):
+        if self.status == Status.created:
+            status = "Created"
+            bg_color = "#caf0f8"
+            border_color = "#48cae4"
+        elif self.status == Status.running:
+            status = "Running"
+            bg_color = "#c7f9cc"
+            border_color = "#78c6a3"
+        elif self.status == Status.closed:
+            status = "Closed"
+            bg_color = "#ffbfad"
+            border_color = "#ff6132"
+
+        html = f"""
+          <div>
+            <div
+                style="
+                width: 24px;
+                height: 24px;
+                background-color: {bg_color};
+                border: 3px solid {border_color};
+                border-radius: 5px;
+                position: absolute;"
+            ></div>
+            <div style="margin-left: 48px">
+                <h3 style="margin-bottom: 0px">{self.__class__.__name__}</h3>
+                <p style="color: #9d9d9d; margin-bottom: 0px">Status: {status}</p>
+            </div>
+            <p>
+            <table style="width: 100%">
+                <tr>
+                <th style="text-align: left; width: 150px">Address</th>
+                <td style="text-align: left">{self.address}</td>
+                </tr>
+                <tr>
+                <th style="text-align: left; width: 150px">External Address</th>
+                <td style="text-align: left">{self.external_address}</td>
+                </tr>
+            </table> </p>
+            </div>
+          </div>
+        """
+
+        return html
+
     async def __aenter__(self):
         await self
         return self

distributed/deploy/ssh.py

@@ -45,6 +45,9 @@ async def close(self):
     def __repr__(self):
         return f"<SSH {type(self).__name__}: status={self.status}>"
 
+    def _repr_html_(self):
+        return super()._repr_html_()
+
 
 class Worker(Process):
     """A Remote Dask Worker controled by SSH
@@ -139,6 +142,12 @@ async def start(self):
         logger.debug("%s", line)
         await super().start()
 
+    def __repr__(self):
+        return f"<SSH {type(self).__name__}: status={self.status}>"
+
+    def _repr_html_(self):
+        return super()._repr_html_()
+
 
 class Scheduler(Process):
     """A Remote Dask Scheduler controlled by SSH
@@ -215,6 +224,12 @@ async def start(self):
         logger.debug("%s", line)
         await super().start()
 
+    def __repr__(self):
+        return f"<SSH {type(self).__name__}: status={self.status}>"
+
+    def _repr_html_(self):
+        return super()._repr_html_()
+
 
 old_cluster_kwargs = {
     "scheduler_addr",