delete tool/path/needcheck attributes

Author: lightislost

muagent/schemas/ekg/ekg_graph.py

@@ -76,7 +76,7 @@ def attrbutes(self, ):
 
 
 class EKGIntentNodeSchema(EKGNodeSchema):
-    path: str = ''
+    # path: str = ''
 
     def attrbutes(self, ):
         extra_attr = json.loads(self.extra)
@@ -107,8 +107,8 @@ def attrbutes(self, ):
         }
 
 class EKGTaskNodeSchema(EKGNodeSchema):
-    tool: str
-    needcheck: bool
+    # tool: str
+    # needcheck: bool
     # when to access
     accesscriteria: str
     # 
@@ -123,7 +123,7 @@ def attrbutes(self, ):
                 "teamids": self.teamids,
                 "accesscriteria": self.accesscriteria,
                 "needcheck": self.needcheck,
-                "tool": self.tool
+                # "tool": self.tool
             }, 
             **extra_attr
         }

muagent/service/ekg_construct/ekg_construct_base.py

@@ -1041,47 +1041,4 @@ def _update_new_attr_for_edges(self, edges: List[GEdge], teamid: str, teamids_by
                 edge.attributes.pop("@timestamp")
             edge.attributes.pop("extra")
         return edges
-    
-    def get_intent_by_alarm(self, alarm: dict, ) -> EKGIntentResp:
-        '''according content search intent'''
-        import requests
-        error_type = alarm.get('errorType', '')
-        title = alarm.get('title', '')
-        content = alarm.get('content', '')
-        biz_code = alarm.get('bizCode', '')
-
-        if not error_type or not title or not content or not biz_code:
-            return None, None
-        
-        alarm = {
-            'type': 'ANTEMC_DINGTALK',
-            'user_input': {
-                'bizCode': biz_code,
-                'title': title,
-                'content': content,
-                'execute_type': 'gql',
-                'errorType': error_type
-            }
-        }
-        
-        body = {
-            'features': {
-                'query': alarm
-            }
-        }
-        intent_url = 'https://paiplusinferencepre.alipay.com/inference/ff998e48456308a9_EKG_route/0.1'
-        headers = {
-                'Content-Type': 'application/json;charset=utf-8',
-                'MPS-app-name': 'test',
-                'MPS-http-version': '1.0'
-            }
-        ans = requests.post(intent_url, json=body, headers=headers)
-
-        ans_json = ans.json()
-        output = ans_json.get('resultMap').get('output')
-        logger.debug(f"{body}")
-        logger.debug(f"{output}")
-        output_json = json.loads(output)
-        res = output_json[-1]
-        all_intent = output_json
-        return res, all_intent
+

tests/service/ekg_construct_test_2.py

@@ -103,12 +103,12 @@ def generate_node(id, type):
         extra_attr["enable"] = False
 
     if type == "opsgptkg_task":
-        extra_attr["accessCriteria"] = "hello"
+        extra_attr["accesscriteria"] = "hello"
 
     if type == "opsgptkg_analysis":
-        extra_attr["accessCriteria"] = "hello"
-        extra_attr["summarySwtich"] = False
-        extra_attr['dslTemplate'] = "hello"        
+        extra_attr["accesscriteria"] = "hello"
+        extra_attr["summaryswtich"] = False
+        extra_attr['dsltemplate'] = "hello"             
 
     return GNode(**{
         "id": id,