Merge branch 'main' into dependabot/uv/uv-0.11.6

Author: gwharris7

.github/workflows/ci.yml

@@ -85,6 +85,8 @@ jobs:
     defaults:
       run:
         working-directory: ./
+    env:
+      PYTHONPATH: ${{ github.workspace }}/versioning/helper
 
     strategy:
       matrix:

CLAUDE.md

@@ -219,6 +219,18 @@ Place it before imports with one blank line after.
 - **Never** use the keyword "Kairo" in code - it's a legacy reference that must be removed/replaced
 - If found during code review, flag for removal
 
+### Observability Export Configuration — Coordinated Review Required
+
+The following three constants must stay in sync. If a PR changes **any one** of them, the reviewer (human or Copilot) **must** ask the author to confirm the other two are still correct:
+
+| Constant | Location |
+|---|---|
+| `PROD_OBSERVABILITY_SCOPE` | `libraries/microsoft-agents-a365-runtime/microsoft_agents_a365/runtime/environment_utils.py` |
+| `DEFAULT_ENDPOINT_URL` | `libraries/microsoft-agents-a365-observability-core/microsoft_agents_a365/observability/core/exporters/agent365_exporter.py` |
+| Export URL path pattern | `build_export_url()` in `libraries/microsoft-agents-a365-observability-core/microsoft_agents_a365/observability/core/exporters/utils.py` |
+
+Snapshot tests in `tests/observability/core/test_export_config_consistency.py` will fail if any value drifts, but the developer must also verify the values are correct for the target environment — the tests only catch accidental drift, not intentional-but-incomplete updates.
+
 ### Python Conventions
 
 - Type hints required on all function parameters and return types

libraries/microsoft-agents-a365-notifications/microsoft_agents_a365/notifications/agent_notification.py

@@ -29,16 +29,17 @@
 #:     notification: The typed notification activity with parsed entities.
 #:
 #: Example:
-#:     ```python
-#:     async def handle_email(
-#:         context: TurnContext,
-#:         state: TurnState,
-#:         notification: AgentNotificationActivity
-#:     ) -> None:
-#:         email = notification.email
-#:         if email:
-#:             print(f"Processing email: {email.id}")
-#:     ```
+#:
+#:     .. code-block:: python
+#:
+#:         async def handle_email(
+#:             context: TurnContext,
+#:             state: TurnState,
+#:             notification: AgentNotificationActivity,
+#:         ) -> None:
+#:             email = notification.email
+#:             if email:
+#:                 print(f"Processing email: {email.id}")
 AgentHandler = Callable[[TContext, TState, AgentNotificationActivity], Awaitable[None]]
 
 
@@ -57,19 +58,19 @@ class AgentNotification:
             defaults to all values in the AgentLifecycleEvent enum.
 
     Example:
-        ```python
-        from microsoft_agents.hosting import Application
-        from microsoft_agents_a365.notifications import AgentNotification
-
-        app = Application()
-        notifications = AgentNotification(app)
-
-        @notifications.on_email()
-        async def handle_email(context, state, notification):
-            email = notification.email
-            if email:
-                await context.send_activity(f"Received email: {email.id}")
-        ```
+        .. code-block:: python
+
+            from microsoft_agents.hosting import Application
+            from microsoft_agents_a365.notifications import AgentNotification
+
+            app = Application()
+            notifications = AgentNotification(app)
+
+            @notifications.on_email()
+            async def handle_email(context, state, notification):
+                email = notification.email
+                if email:
+                    await context.send_activity(f"Received email: {email.id}")
     """
 
     def __init__(
@@ -126,15 +127,15 @@ def on_agent_notification(
             A decorator function that registers the handler with the application.
 
         Example:
-            ```python
-            from microsoft_agents.activity import ChannelId
+            .. code-block:: python
 
-            @notifications.on_agent_notification(
-                ChannelId(channel="agents", sub_channel="email")
-            )
-            async def handle_custom_channel(context, state, notification):
-                print(f"Received notification on {notification.channel}/{notification.sub_channel}")
-            ```
+                from microsoft_agents.activity import ChannelId
+
+                @notifications.on_agent_notification(
+                    ChannelId(channel="agents", sub_channel="email")
+                )
+                async def handle_custom_channel(context, state, notification):
+                    print(f"Received notification on {notification.channel}/{notification.sub_channel}")
         """
         registered_channel = channel_id.channel.lower()
         registered_subchannel = (channel_id.sub_channel or "*").lower()
@@ -184,11 +185,11 @@ def on_agent_lifecycle_notification(
             A decorator function that registers the handler with the application.
 
         Example:
-            ```python
-            @notifications.on_agent_lifecycle_notification("agenticuseridentitycreated")
-            async def handle_user_created(context, state, notification):
-                print("New user created")
-            ```
+            .. code-block:: python
+
+                @notifications.on_agent_lifecycle_notification("agenticuseridentitycreated")
+                async def handle_user_created(context, state, notification):
+                    print("New user created")
         """
 
         def route_selector(context: TurnContext) -> bool:
@@ -234,18 +235,17 @@ def on_email(
             A decorator function that registers the handler with the application.
 
         Example:
-            ```python
-            @notifications.on_email()
-            async def handle_email(context, state, notification):
-                email = notification.email
-                if email:
-                    print(f"Received email: {email.id}")
-                    # Send a response
-                    response = EmailResponse.create_email_response_activity(
-                        "<p>Thank you for your email.</p>"
-                    )
-                    await context.send_activity(response)
-            ```
+            .. code-block:: python
+
+                @notifications.on_email()
+                async def handle_email(context, state, notification):
+                    email = notification.email
+                    if email:
+                        print(f"Received email: {email.id}")
+                        response = EmailResponse.create_email_response_activity(
+                            "<p>Thank you for your email.</p>"
+                        )
+                        await context.send_activity(response)
         """
         return self.on_agent_notification(
             ChannelId(channel="agents", sub_channel=AgentSubChannel.EMAIL), **kwargs
@@ -266,13 +266,13 @@ def on_word(
             A decorator function that registers the handler with the application.
 
         Example:
-            ```python
-            @notifications.on_word()
-            async def handle_word_comment(context, state, notification):
-                comment = notification.wpx_comment
-                if comment:
-                    print(f"Received Word comment: {comment.comment_id}")
-            ```
+            .. code-block:: python
+
+                @notifications.on_word()
+                async def handle_word_comment(context, state, notification):
+                    comment = notification.wpx_comment
+                    if comment:
+                        print(f"Received Word comment: {comment.comment_id}")
         """
         return self.on_agent_notification(
             ChannelId(channel="agents", sub_channel=AgentSubChannel.WORD), **kwargs
@@ -293,13 +293,13 @@ def on_excel(
             A decorator function that registers the handler with the application.
 
         Example:
-            ```python
-            @notifications.on_excel()
-            async def handle_excel_comment(context, state, notification):
-                comment = notification.wpx_comment
-                if comment:
-                    print(f"Received Excel comment: {comment.comment_id}")
-            ```
+            .. code-block:: python
+
+                @notifications.on_excel()
+                async def handle_excel_comment(context, state, notification):
+                    comment = notification.wpx_comment
+                    if comment:
+                        print(f"Received Excel comment: {comment.comment_id}")
         """
         return self.on_agent_notification(
             ChannelId(channel="agents", sub_channel=AgentSubChannel.EXCEL), **kwargs
@@ -320,13 +320,13 @@ def on_powerpoint(
             A decorator function that registers the handler with the application.
 
         Example:
-            ```python
-            @notifications.on_powerpoint()
-            async def handle_powerpoint_comment(context, state, notification):
-                comment = notification.wpx_comment
-                if comment:
-                    print(f"Received PowerPoint comment: {comment.comment_id}")
-            ```
+            .. code-block:: python
+
+                @notifications.on_powerpoint()
+                async def handle_powerpoint_comment(context, state, notification):
+                    comment = notification.wpx_comment
+                    if comment:
+                        print(f"Received PowerPoint comment: {comment.comment_id}")
         """
         return self.on_agent_notification(
             ChannelId(channel="agents", sub_channel=AgentSubChannel.POWERPOINT), **kwargs
@@ -347,11 +347,11 @@ def on_lifecycle(
             A decorator function that registers the handler with the application.
 
         Example:
-            ```python
-            @notifications.on_lifecycle()
-            async def handle_any_lifecycle_event(context, state, notification):
-                print(f"Lifecycle event type: {notification.notification_type}")
-            ```
+            .. code-block:: python
+
+                @notifications.on_lifecycle()
+                async def handle_any_lifecycle_event(context, state, notification):
+                    print(f"Lifecycle event type: {notification.notification_type}")
         """
         return self.on_lifecycle_notification("*", **kwargs)
 
@@ -370,11 +370,11 @@ def on_user_created(
             A decorator function that registers the handler with the application.
 
         Example:
-            ```python
-            @notifications.on_user_created()
-            async def handle_user_created(context, state, notification):
-                print("New agentic user identity created")
-            ```
+            .. code-block:: python
+
+                @notifications.on_user_created()
+                async def handle_user_created(context, state, notification):
+                    print("New agentic user identity created")
         """
         return self.on_lifecycle_notification(AgentLifecycleEvent.USERCREATED, **kwargs)
 
@@ -393,11 +393,11 @@ def on_user_workload_onboarding(
             A decorator function that registers the handler with the application.
 
         Example:
-            ```python
-            @notifications.on_user_workload_onboarding()
-            async def handle_onboarding_update(context, state, notification):
-                print("User workload onboarding status updated")
-            ```
+            .. code-block:: python
+
+                @notifications.on_user_workload_onboarding()
+                async def handle_onboarding_update(context, state, notification):
+                    print("User workload onboarding status updated")
         """
         return self.on_lifecycle_notification(
             AgentLifecycleEvent.USERWORKLOADONBOARDINGUPDATED, **kwargs
@@ -418,11 +418,11 @@ def on_user_deleted(
             A decorator function that registers the handler with the application.
 
         Example:
-            ```python
-            @notifications.on_user_deleted()
-            async def handle_user_deleted(context, state, notification):
-                print("Agentic user identity deleted")
-            ```
+            .. code-block:: python
+
+                @notifications.on_user_deleted()
+                async def handle_user_deleted(context, state, notification):
+                    print("Agentic user identity deleted")
         """
         return self.on_lifecycle_notification(AgentLifecycleEvent.USERDELETED, **kwargs)
 

libraries/microsoft-agents-a365-notifications/microsoft_agents_a365/notifications/models/agent_notification_activity.py

@@ -28,13 +28,17 @@ class AgentNotificationActivity:
         activity: The underlying Activity object.
 
     Example:
-        ```python
-        async def email_handler(context: TurnContext, state: TurnState, notification: AgentNotificationActivity):
-            email = notification.email
-            if email:
-                print(f"Received email: {email.id}")
-                print(f"Body: {email.html_body}")
-        ```
+        .. code-block:: python
+
+            async def email_handler(
+                context: TurnContext,
+                state: TurnState,
+                notification: AgentNotificationActivity,
+            ) -> None:
+                email = notification.email
+                if email:
+                    print(f"Received email: {email.id}")
+                    print(f"Body: {email.html_body}")
     """
 
     def __init__(self, activity: Activity):
@@ -158,17 +162,17 @@ def as_model(self, model: Type[TModel]) -> Optional[TModel]:
             An instance of the specified model type if validation succeeds, otherwise None.
 
         Example:
-            ```python
-            from pydantic import BaseModel
+            .. code-block:: python
 
-            class CustomNotification(BaseModel):
-                custom_field: str
+                from pydantic import BaseModel
 
-            notification = AgentNotificationActivity(activity)
-            custom = notification.as_model(CustomNotification)
-            if custom:
-                print(custom.custom_field)
-            ```
+                class CustomNotification(BaseModel):
+                    custom_field: str
+
+                notification = AgentNotificationActivity(activity)
+                custom = notification.as_model(CustomNotification)
+                if custom:
+                    print(custom.custom_field)
         """
         try:
             return model.model_validate(self.value or {})

libraries/microsoft-agents-a365-notifications/microsoft_agents_a365/notifications/models/email_response.py

@@ -36,12 +36,12 @@ def create_email_response_activity(email_response_html_body: str) -> Activity:
             entity attached to its entities list.
 
         Example:
-            ```python
-            activity = EmailResponse.create_email_response_activity(
-                "<p>Thank you for your email. I'll get back to you soon.</p>"
-            )
-            await context.send_activity(activity)
-            ```
+            .. code-block:: python
+
+                activity = EmailResponse.create_email_response_activity(
+                    "<p>Thank you for your email. I'll get back to you soon.</p>"
+                )
+                await context.send_activity(activity)
         """
         working_activity = Activity(type="message")
         email_response = EmailResponse(html_body=email_response_html_body)

libraries/microsoft-agents-a365-notifications/pyproject.toml

@@ -1,7 +1,6 @@
 [build-system]
 requires = ["setuptools>=68", "wheel", "tzdata", "tomlkit", "packaging"]
 build-backend = "build_backend"
-backend-path = ["../../versioning/helper"]
 
 [project]
 name = "microsoft-agents-a365-notifications"

libraries/microsoft-agents-a365-observability-core/microsoft_agents_a365/observability/core/config.py

@@ -180,6 +180,7 @@ def _configure_internal(
                 token_resolver=exporter_options.token_resolver,
                 cluster_category=exporter_options.cluster_category,
                 use_s2s_endpoint=exporter_options.use_s2s_endpoint,
+                max_payload_bytes=exporter_options.max_payload_bytes,
             )
 
         else: