chore(release): bump version to 6.1.15

Co-authored-by: Junie <junie@egeria-project.org>

Author: dwolfson

PYEGERIA_ISSUES.md

@@ -225,7 +225,7 @@ read. Full draft: trellis session scratch `egeria-issue-engine-host-403-loop.md`
 
 ### ISSUE-93: `declassify_metadata_element` raises `AttributeError` when `body` is omitted, though the parameter is Optional — and the classification is silently left in place
 
-**Layer:** Pyegeria · **Status:** open · **Found:** 2026-09-08 (Resource Explorer, swapping a Project's kind classification during investigation reclassification).
+**Layer:** Pyegeria · **Status:** fixed (2026-09-13) · **Found:** 2026-09-08 (Resource Explorer, swapping a Project's kind classification during investigation reclassification).
 
 `MetadataExpert.declassify_metadata_element(metadata_element_guid, classification_name, body=None)`
 declares `body` as `Optional[dict | MetadataSourceRequestBody] = None`, but the
@@ -282,7 +282,7 @@ rather than only that the new one is present.
 
 ### ISSUE-92: `Project Type`'s description in `commands_project_compact.json` lists only 4 of its 6 `valid_values` — omits `Project` and `Experiment`, and the stale text is baked into 24 generated files
 
-**Layer:** Pyegeria · **Status:** open · **Found:** 2026-09-07 (Resource
+**Layer:** Pyegeria · **Status:** fixed (2026-09-13) · **Found:** 2026-09-07 (Resource
 Explorer, designing investigation → Egeria Project classification mapping).
 
 `md_processing/data/compact_commands/commands_project_compact.json`, the
@@ -369,7 +369,7 @@ check that flags a `description` naming a subset of its own `valid_values`.
 
 ### ISSUE-91: `pyegeria.core.mcp_server` imports `mcp.server.mcpserver` (mcp 2.x only) but `pyproject.toml` declares `mcp >=0.1` — any consumer that resolves mcp 1.x gets a server that dies at import
 
-**Layer:** pyegeria packaging · **Status:** open · **Found:** 2026-09-05 (Egeria Advisor dev startup on the M3 Max)
+**Layer:** pyegeria packaging · **Status:** fixed (2026-09-13) · **Found:** 2026-09-05 (Egeria Advisor dev startup on the M3 Max)
 
 Commit 2b39ba06 (2026-07-30, "migrate mcp_server.py to mcp 2.0.0's MCPServer") changed the
 server's import to:
@@ -965,7 +965,7 @@ into the entry now, so it isn't rediscovered from scratch later.
 
 ### ISSUE-96: get_guid_for_name (and every other sync wrapper using asyncio.get_event_loop().run_until_complete(...)) breaks when a client instance is reused across threads — surfaces as a misleading CLIENT_ERROR_400 "unable to connect"
 
-Layer: pyegeria core (_base_server_client.py, _base_platform_client.py, every OMVS class's sync wrappers) · Status: open · Found: 2026-09-12 (Resource Explorer, SurveyDefinitionReader._lookup_question_guid)
+Layer: pyegeria core (_base_server_client.py, _base_platform_client.py, every OMVS class's sync wrappers) · Status: fixed (2026-09-13) · Found: 2026-09-12 (Resource Explorer, SurveyDefinitionReader._lookup_question_guid)
 
 A single client instance (e.g. ClassificationExplorer) constructed once
 and reused from multiple threads — a natural pattern for any caller with a

md_processing/data/compact_commands/commands_project_compact.json

@@ -2621,7 +2621,7 @@
         "Experiment"
       ],
       "existing_element": "",
-      "description": "A string classifying the project. Supported values are Campaign, Task, PersonalProject and StudyProject.",
+      "description": "A string classifying the project. `Project` (the default) applies no classification. `Campaign` is a long-term strategic initiative delivered through multiple projects; `Task` a self-contained short activity; `PersonalProject` an informal project an individual creates to organize their own work; `StudyProject` a focused analysis of a topic, person, object or situation; `Experiment` a project testing a hypothesis, which is recorded in the `hypothesis` attribute.",
       "generated": false,
       "style": "Enum",
       "user_specified": true,

pyegeria/core/_base_platform_client.py

@@ -11,6 +11,7 @@
 import inspect
 import json
 import os
+import threading
 
 import httpcore
 import httpx
@@ -125,15 +126,8 @@ def __init__(
             self.headers["Authorization"] = f"Bearer {self.token}"
             self.text_headers["Authorization"] = f"Bearer {self.token}"
 
-        self.session = AsyncClient(
-            verify=enable_ssl_check,
-            timeout=httpx.Timeout(timeout=float(self.timeout), connect=10.0),
-            limits=httpx.Limits(
-                max_connections=10,
-                max_keepalive_connections=5,
-                keepalive_expiry=20.0,  # stay under typical reverse-proxy idle timeout (60-75 s)
-            ),
-        )
+        self._thread_local = threading.local()
+
         self.command_root: str = f"{self.platform_url}/servers/{self.server_name}/api/open-metadata/"
 
         try:
@@ -142,6 +136,26 @@ def __init__(
         except PyegeriaConnectionException as e:
             raise
 
+    @property
+    def session(self) -> AsyncClient:
+        """Get the httpx session for the current thread."""
+        if not hasattr(self._thread_local, "session"):
+            self._thread_local.session = AsyncClient(
+                verify=enable_ssl_check,
+                timeout=httpx.Timeout(timeout=float(self.timeout), connect=10.0),
+                limits=httpx.Limits(
+                    max_connections=10,
+                    max_keepalive_connections=5,
+                    keepalive_expiry=20.0,  # stay under typical reverse-proxy idle timeout (60-75 s)
+                ),
+            )
+        return self._thread_local.session
+
+    @session.setter
+    def session(self, value: AsyncClient):
+        """Allow setting the session for the current thread."""
+        self._thread_local.session = value
+
     async def _async_check_connection(self) -> str:
         """Check if the connection is working. Async version.
 

pyegeria/core/_base_server_client.py

@@ -11,6 +11,7 @@
 import inspect
 import json
 import os
+import threading
 
 import httpcore
 import httpx
@@ -124,10 +125,8 @@ def __init__(
             self.headers["Authorization"] = f"Bearer {self.token}"
             self.text_headers["Authorization"] = f"Bearer {self.token}"
 
-        self.session = AsyncClient(
-            verify=enable_ssl_check,
-            timeout=httpx.Timeout(timeout=float(self.timeout), connect=10.0),
-        )
+        self._thread_local = threading.local()
+
         self.command_root: str = f"{self.platform_url}/servers/{self.server_name}/api/open-metadata/"
 
         try:
@@ -136,6 +135,21 @@ def __init__(
         except PyegeriaConnectionException:
             raise
 
+    @property
+    def session(self) -> AsyncClient:
+        """Get the httpx session for the current thread."""
+        if not hasattr(self._thread_local, "session"):
+            self._thread_local.session = AsyncClient(
+                verify=enable_ssl_check,
+                timeout=httpx.Timeout(timeout=float(self.timeout), connect=10.0),
+            )
+        return self._thread_local.session
+
+    @session.setter
+    def session(self, value: AsyncClient):
+        """Allow setting the session for the current thread."""
+        self._thread_local.session = value
+
     async def _async_check_connection(self) -> str:
         """Check if the connection is working. Async version.
 

pyegeria/core/_server_client.py

@@ -6248,33 +6248,36 @@ def validate_update_element_request(self, body: dict | UpdateElementRequestBody
         return validated_body
 
     @dynamic_catch
-    def validate_update_properties_request(self, body: dict | UpdatePropertiesRequestBody) -> UpdatePropertiesRequestBody | None:
+    def validate_update_properties_request(self, body: Optional[dict | UpdatePropertiesRequestBody] = None) -> UpdatePropertiesRequestBody | None:
         if isinstance(body, UpdatePropertiesRequestBody):
             validated_body = body
         elif isinstance(body, dict):
             validated_body = self._validate_body(self._update_properties_request_adapter.validate_python, body)
         else:
-            validated_body = None
+            body = {"class": "UpdatePropertiesRequestBody"}
+            validated_body = self._validate_body(UpdatePropertiesRequestBody.model_validate, body)
         return validated_body
 
     @dynamic_catch
-    def validate_metadata_source_request(self, body: dict | MetadataSourceRequestBody) -> MetadataSourceRequestBody | None:
+    def validate_metadata_source_request(self, body: Optional[dict | MetadataSourceRequestBody] = None) -> MetadataSourceRequestBody | None:
         if isinstance(body, MetadataSourceRequestBody):
             validated_body = body
         elif isinstance(body, dict):
             validated_body = self._validate_body(self._metadata_source_request_adapter.validate_python, body)
         else:
-            validated_body = None
+            body = {"class": "MetadataSourceRequestBody"}
+            validated_body = self._validate_body(MetadataSourceRequestBody.model_validate, body)
         return validated_body
 
     @dynamic_catch
-    def validate_update_effectivity_dates_request(self, body: dict | UpdateEffectivityDatesRequestBody) -> UpdateEffectivityDatesRequestBody | None:
+    def validate_update_effectivity_dates_request(self, body: Optional[dict | UpdateEffectivityDatesRequestBody] = None) -> UpdateEffectivityDatesRequestBody | None:
         if isinstance(body, UpdateEffectivityDatesRequestBody):
             validated_body = body
         elif isinstance(body, dict):
             validated_body = self._validate_body(self._update_effectivity_dates_request_adapter.validate_python, body)
         else:
-            validated_body = None
+            body = {"class": "UpdateEffectivityDatesRequestBody"}
+            validated_body = self._validate_body(UpdateEffectivityDatesRequestBody.model_validate, body)
         return validated_body
 
     @dynamic_catch
@@ -6289,33 +6292,36 @@ def validate_open_metadata_delete_request(self, body: Optional[dict | OpenMetada
         return validated_body
 
     @dynamic_catch
-    def validate_archive_request(self, body: dict | DeleteElementRequestBody) -> DeleteElementRequestBody | None:
+    def validate_archive_request(self, body: Optional[dict | DeleteElementRequestBody] = None) -> DeleteElementRequestBody | None:
         if isinstance(body, DeleteElementRequestBody):
             validated_body = body
         elif isinstance(body, dict):
             validated_body = self._validate_body(self._delete_element_request_adapter.validate_python, body)
         else:
-            validated_body = None
+            body = {"class": "DeleteElementRequestBody"}
+            validated_body = self._validate_body(DeleteElementRequestBody.model_validate, body)
         return validated_body
 
     @dynamic_catch
-    def validate_new_open_metadata_element_request(self, body: dict | NewOpenMetadataElementRequestBody) -> NewOpenMetadataElementRequestBody | None:
+    def validate_new_open_metadata_element_request(self, body: Optional[dict | NewOpenMetadataElementRequestBody] = None) -> NewOpenMetadataElementRequestBody | None:
         if isinstance(body, NewOpenMetadataElementRequestBody):
             validated_body = body
         elif isinstance(body, dict):
             validated_body = self._validate_body(self._new_open_metadata_element_request_adapter.validate_python, body)
         else:
-            validated_body = None
+            body = {"class": "NewOpenMetadataElementRequestBody"}
+            validated_body = self._validate_body(NewOpenMetadataElementRequestBody.model_validate, body)
         return validated_body
 
     @dynamic_catch
-    def validate_new_related_elements_request(self, body: dict | NewRelatedElementsRequestBody) -> NewRelatedElementsRequestBody | None:
+    def validate_new_related_elements_request(self, body: Optional[dict | NewRelatedElementsRequestBody] = None) -> NewRelatedElementsRequestBody | None:
         if isinstance(body, NewRelatedElementsRequestBody):
             validated_body = body
         elif isinstance(body, dict):
             validated_body = self._validate_body(self._new_related_elements_request_adapter.validate_python, body)
         else:
-            validated_body = None
+            body = {"class": "NewRelatedElementsRequestBody"}
+            validated_body = self._validate_body(NewRelatedElementsRequestBody.model_validate, body)
         return validated_body
 
     @dynamic_catch

pyproject.toml

@@ -3,7 +3,7 @@
 
 [project]
 name = "pyegeria"
-version = "6.1.14"
+version = "6.1.15"
 license = 'Apache-2.0'
 license-files = ["LICENSE"]
 authors = [{name = "Dan Wolfson", email = "dan.wolfson@pdr-associates.com"},]
@@ -36,7 +36,7 @@ dependencies = [
     "pydevd-pycharm >=253.27642.35",
     "wcwidth",
     "altair==6.2.2",
-    "mcp >=0.1",
+    "mcp >=2.1.1",
     "markers>=0.3.0",
     "pytest-asyncio>=1.2.0",
     "python-dotenv>=1.1.1",

sample-data/templates/advanced/Projects/Create_Campaign.md

@@ -130,7 +130,7 @@ ___
 
 >	**Attribute Type**: Enum
 
->	**Description**: A string classifying the project. Supported values are Campaign, Task, PersonalProject and StudyProject.
+>	**Description**: A string classifying the project. `Project` (the default) applies no classification. `Campaign` is a long-term strategic initiative delivered through multiple projects; `Task` a self-contained short activity; `PersonalProject` an informal project an individual creates to organize their own work; `StudyProject` a focused analysis of a topic, person, object or situation; `Experiment` a project testing a hypothesis, which is recorded in the `hypothesis` attribute.
 
 >	**Valid Values**: Project,Campaign,Task,PersonalProject,StudyProject,Experiment
 

sample-data/templates/advanced/Projects/Create_Experiment.md

@@ -130,7 +130,7 @@ ___
 
 >	**Attribute Type**: Enum
 
->	**Description**: A string classifying the project. Supported values are Campaign, Task, PersonalProject and StudyProject.
+>	**Description**: A string classifying the project. `Project` (the default) applies no classification. `Campaign` is a long-term strategic initiative delivered through multiple projects; `Task` a self-contained short activity; `PersonalProject` an informal project an individual creates to organize their own work; `StudyProject` a focused analysis of a topic, person, object or situation; `Experiment` a project testing a hypothesis, which is recorded in the `hypothesis` attribute.
 
 >	**Valid Values**: Project,Campaign,Task,PersonalProject,StudyProject,Experiment
 

sample-data/templates/advanced/Projects/Create_Glossary_Project.md

@@ -130,7 +130,7 @@ ___
 
 >	**Attribute Type**: Enum
 
->	**Description**: A string classifying the project. Supported values are Campaign, Task, PersonalProject and StudyProject.
+>	**Description**: A string classifying the project. `Project` (the default) applies no classification. `Campaign` is a long-term strategic initiative delivered through multiple projects; `Task` a self-contained short activity; `PersonalProject` an informal project an individual creates to organize their own work; `StudyProject` a focused analysis of a topic, person, object or situation; `Experiment` a project testing a hypothesis, which is recorded in the `hypothesis` attribute.
 
 >	**Valid Values**: Project,Campaign,Task,PersonalProject,StudyProject,Experiment
 

sample-data/templates/advanced/Projects/Create_Governance_Project.md

@@ -130,7 +130,7 @@ ___
 
 >	**Attribute Type**: Enum
 
->	**Description**: A string classifying the project. Supported values are Campaign, Task, PersonalProject and StudyProject.
+>	**Description**: A string classifying the project. `Project` (the default) applies no classification. `Campaign` is a long-term strategic initiative delivered through multiple projects; `Task` a self-contained short activity; `PersonalProject` an informal project an individual creates to organize their own work; `StudyProject` a focused analysis of a topic, person, object or situation; `Experiment` a project testing a hypothesis, which is recorded in the `hypothesis` attribute.
 
 >	**Valid Values**: Project,Campaign,Task,PersonalProject,StudyProject,Experiment