[{'Text': 'Edited point-topic-mcp/src/point_topic_mcp/core/mongodb_utils.py:\n\n```diff\n@@ -213,6 +213,16 @@\n     return data if isinstance(data, list) else [data]\n \n \n+def run_aggregation(pipeline: list, collection: str = "Operator", timeout: int = 60) -> list:\n+    """Run an aggregation pipeline and return results as list of dicts.\n+\n+     Efficient batch query, key for replacing N+1 individual calls.\n+    """\n+    js = f"EJSON.stringify(db.{collection}.aggregate({json.dumps(pipeline)}).toArray())"\n+    out = _run_mongosh(js, timeout=timeout)\n+    return json.loads(out) if out else []\n+\n+\n def mongosh_available() -> bool:\n     """Check if mongosh is installed and can connect."""\n     try:\n\n```'}]