[Feat][Core/Dashboard] Convert DataHead to subprocess module (#51507)

Signed-off-by: Chi-Sheng Liu <chishengliu@chishengliu.com>

Author: MortalHappiness

python/ray/dashboard/modules/data/data_head.py

@@ -8,7 +8,8 @@
 from aiohttp.web import Request, Response
 
 import ray.dashboard.optional_utils as optional_utils
-import ray.dashboard.utils as dashboard_utils
+from ray.dashboard.subprocesses.routes import SubprocessRouteTable as routes
+from ray.dashboard.subprocesses.module import SubprocessModule
 from ray.dashboard.modules.metrics.metrics_head import (
     DEFAULT_PROMETHEUS_HEADERS,
     DEFAULT_PROMETHEUS_HOST,
@@ -48,9 +49,9 @@ class PrometheusQuery(Enum):
 }
 
 
-class DataHead(dashboard_utils.DashboardHeadModule):
-    def __init__(self, config: dashboard_utils.DashboardHeadModuleConfig):
-        super().__init__(config)
+class DataHead(SubprocessModule):
+    def __init__(self, *args, **kwargs):
+        super().__init__(*args, **kwargs)
         self.prometheus_host = os.environ.get(
             PROMETHEUS_HOST_ENV_VAR, DEFAULT_PROMETHEUS_HOST
         )
@@ -61,7 +62,7 @@ def __init__(self, config: dashboard_utils.DashboardHeadModuleConfig):
             )
         )
 
-    @optional_utils.DashboardHeadRouteTable.get("/api/data/datasets/{job_id}")
+    @routes.get("/api/data/datasets/{job_id}")
     @optional_utils.init_ray_and_catch_exceptions()
     async def get_datasets(self, req: Request) -> Response:
         job_id = req.match_info["job_id"]
@@ -147,13 +148,6 @@ async def get_datasets(self, req: Request) -> Response:
                 text=str(e),
             )
 
-    async def run(self, server):
-        pass
-
-    @staticmethod
-    def is_minimal_module():
-        return False
-
     async def _query_prometheus(self, query):
         async with self.http_session.get(
             f"{self.prometheus_host}/api/v1/query?query={quote(query)}",