Spaces:
Running
Running
cleanup
Browse files- src/compiler.py +0 -58
src/compiler.py
CHANGED
|
@@ -1,61 +1,3 @@
|
|
| 1 |
-
# """
|
| 2 |
-
# Stage 3: Response Compiler - Data Fusion
|
| 3 |
-
# """
|
| 4 |
-
|
| 5 |
-
# from typing import Dict, Any, List
|
| 6 |
-
|
| 7 |
-
|
| 8 |
-
# class ResponseCompiler:
|
| 9 |
-
# """Stage 3: Compile results from multiple servers"""
|
| 10 |
-
|
| 11 |
-
# def compile(self, raw_results: Dict[str, Any]) -> Dict[str, Any]:
|
| 12 |
-
# """
|
| 13 |
-
# Merge results into structured format
|
| 14 |
-
|
| 15 |
-
# Args:
|
| 16 |
-
# raw_results: Dictionary containing results from MCPExecutor
|
| 17 |
-
# {
|
| 18 |
-
# "results": {
|
| 19 |
-
# "weather": {"status": "success", "data": {...}},
|
| 20 |
-
# "soil_properties": {"status": "success", "data": {...}},
|
| 21 |
-
# ...
|
| 22 |
-
# },
|
| 23 |
-
# "execution_time_seconds": 3.5
|
| 24 |
-
# }
|
| 25 |
-
|
| 26 |
-
# Returns:
|
| 27 |
-
# {
|
| 28 |
-
# "successful_servers": List[str],
|
| 29 |
-
# "failed_servers": List[dict],
|
| 30 |
-
# "data": Dict[str, Any],
|
| 31 |
-
# "execution_time": float,
|
| 32 |
-
# "completeness": str
|
| 33 |
-
# }
|
| 34 |
-
# """
|
| 35 |
-
# results_dict = raw_results.get("results", {})
|
| 36 |
-
|
| 37 |
-
# successful = []
|
| 38 |
-
# failed = []
|
| 39 |
-
# compiled_data = {}
|
| 40 |
-
|
| 41 |
-
# for server_name, result in results_dict.items():
|
| 42 |
-
# if result.get("status") == "success":
|
| 43 |
-
# successful.append(server_name)
|
| 44 |
-
# compiled_data[server_name] = result.get("data", {})
|
| 45 |
-
# else:
|
| 46 |
-
# failed.append({
|
| 47 |
-
# "server": server_name,
|
| 48 |
-
# "error": result.get("error", "Unknown error")
|
| 49 |
-
# })
|
| 50 |
-
|
| 51 |
-
# return {
|
| 52 |
-
# "successful_servers": successful,
|
| 53 |
-
# "failed_servers": failed,
|
| 54 |
-
# "data": compiled_data,
|
| 55 |
-
# "execution_time": raw_results.get("execution_time_seconds", 0),
|
| 56 |
-
# "completeness": f"{len(successful)}/{len(results_dict)} servers"
|
| 57 |
-
# }
|
| 58 |
-
|
| 59 |
"""
|
| 60 |
Response Compiler - Stage 3
|
| 61 |
Compiles MCP results with focus on ALERTING INFORMATION ONLY
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1 |
"""
|
| 2 |
Response Compiler - Stage 3
|
| 3 |
Compiles MCP results with focus on ALERTING INFORMATION ONLY
|