finalise log analysis

Author: CTY-git

patchwork/patchflows/LogAnalysis/LogAnalysis.py

@@ -1,4 +1,5 @@
 import json
+import os
 from pathlib import Path
 
 import yaml
@@ -15,26 +16,19 @@
 class LogAnalysis(Step):
     def __init__(self, inputs: dict):
         PatchflowProgressBar(self).register_steps(
-            # CallSQL,
             AgenticLLMV2,
         )
         final_inputs = yaml.safe_load(_DEFAULT_INPUT_FILE.read_text()) or dict()
         final_inputs.update(inputs)
 
         validate_steps_with_inputs(
             set(final_inputs.keys()).union({""}),
-            # CallSQL,
             AgenticLLMV2,
         )
 
         self.inputs = final_inputs
 
     def run(self) -> dict:
-        # output = CallSQL(self.inputs).run()
-        # self.inputs.update(output)
-
-        log_filename = "gcp_logs.log"
-        sentry_filename = "sentry_issues.json"
         for i in range(self.inputs.get("analysis_limit") or 5):
             # for i in range(self.inputs.get("log_finding_limit") or sys.maxsize):
             logs_detection_output = AgenticLLMV2(
@@ -46,12 +40,9 @@ def run(self) -> dict:
 Explore the logs and reply with the relevant logs position, the file path and line number.  
 """,
                     user_prompt=f"""\
-The log file {log_filename} from GCP and the sentry logs can be found at {sentry_filename}.
+Logs are uploaded to the current working directory at {os.getcwd()}.
 
-Here are some relevant information:
-Custom Patchflow Id: 5826
-Organisation Id: 301
-Repository Id: 456
+{self.inputs.get('query')}
 """,
                     example_json="""
 {
@@ -94,6 +85,7 @@ def run(self) -> dict:
             if analysis_output.get("is_log_analysis_done", False):
                 break
 
-        logger.info(json.dumps(logs_detection_output))
-        logger.info(json.dumps(analysis_output))
+        logger.info("Log Analysis Complete")
+        logger.info("Message:")
+        logger.info(json.dumps(analysis_output.get("message")))
         return dict()

patchwork/patchflows/LogAnalysis/defaults.yml

@@ -0,0 +1 @@
+query: ""