feat: exclude remote model for admin UI (#225)

Signed-off-by: Lin Wang <[email protected]>
opensearch-project · Jul 3, 2023 · ba01d34 · ba01d34
1 parent e2825c4
commit ba01d34
Show file tree

Hide file tree

Showing 5 changed files with 23 additions and 5 deletions.
diff --git a/public/apis/model.ts b/public/apis/model.ts
@@ -30,6 +30,7 @@ export class Model {
     size: number;
     states?: MODEL_STATE[];
     nameOrId?: string;
+    exclude?: 'REMOTE_MODEL';
   }) {
     return InnerHttpProvider.getHttp().get<ModelSearchResponse>(MODEL_API_ENDPOINT, {
       query,

diff --git a/public/components/monitoring/use_monitoring.ts b/public/components/monitoring/use_monitoring.ts
@@ -47,6 +47,7 @@ const fetchDeployedModels = async (params: Params) => {
         ? [MODEL_STATE.loadFailed, MODEL_STATE.loaded, MODEL_STATE.partiallyLoaded]
         : states,
     sort: [`${params.sort.field}-${params.sort.direction}`],
+    exclude: 'REMOTE_MODEL',
   });
   const totalPages = Math.ceil(result.total_models / params.pageSize);
   return {

diff --git a/server/routes/model_router.ts b/server/routes/model_router.ts
@@ -42,11 +42,12 @@ export const modelRouter = (router: IRouter) => {
           ),
           states: schema.maybe(schema.oneOf([schema.arrayOf(modelStateSchema), modelStateSchema])),
           nameOrId: schema.maybe(schema.string()),
+          exclude: schema.maybe(schema.literal('REMOTE_MODEL')),
         }),
       },
     },
     async (context, request) => {
-      const { from, size, sort, states, nameOrId } = request.query;
+      const { from, size, sort, states, nameOrId, exclude } = request.query;
       try {
         const payload = await ModelService.search({
           client: context.core.opensearch.client,
@@ -55,6 +56,7 @@ export const modelRouter = (router: IRouter) => {
           sort: typeof sort === 'string' ? [sort] : sort,
           states: typeof states === 'string' ? [states] : states,
           nameOrId,
+          exclude,
         });
         return opensearchDashboardsResponseFactory.ok({ body: payload });
       } catch (err) {

diff --git a/server/services/model_service.ts b/server/services/model_service.ts
@@ -43,6 +43,7 @@ export class ModelService {
     sort?: ModelSearchSort[];
     states?: MODEL_STATE[];
     nameOrId?: string;
+    exclude?: 'REMOTE_MODEL';
   }) {
     const {
       body: { hits },

diff --git a/server/services/utils/model.ts b/server/services/utils/model.ts
@@ -9,9 +9,11 @@ import { generateTermQuery } from './query';
 export const generateModelSearchQuery = ({
   states,
   nameOrId,
+  exclude,
 }: {
   states?: MODEL_STATE[];
   nameOrId?: string;
+  exclude?: 'REMOTE_MODEL';
 }) => ({
   bool: {
     must: [
@@ -33,10 +35,21 @@ export const generateModelSearchQuery = ({
           ]
         : []),
     ],
-    must_not: {
-      exists: {
-        field: 'chunk_number',
+    must_not: [
+      {
+        exists: {
+          field: 'chunk_number',
+        },
       },
-    },
+      ...(exclude === 'REMOTE_MODEL'
+        ? [
+            {
+              term: {
+                algorithm: 'REMOTE',
+              },
+            },
+          ]
+        : []),
+    ],
   },
 });