chore(agentserver-activity): simplify sample logging and debug output

Author: Hameedkunkanoor

sdk/agentserver/azure-ai-agentserver-activity/samples/echo-agent/main.py

@@ -1,73 +1,39 @@
 # Copyright (c) Microsoft. All rights reserved.
 
-"""Tier 1 ΓÇö Zero-Config Activity Protocol Agent (with debug logging).
+"""Tier 1 - Zero-Config Activity Protocol Agent.
 
 The simplest possible activity protocol agent. The package auto-initializes
 the M365 Agents SDK from environment variables, applies MSAL auth patches,
 and bridges activities to the AgentApplication turn pipeline.
 
-You write only handler logic ΓÇö no SDK wiring needed.
+You write only handler logic - no SDK wiring needed.
 """
 
-import logging
-from os import environ
-
-logging.basicConfig(level=logging.DEBUG, format="%(asctime)s %(levelname)s %(name)s | %(message)s")
-logger = logging.getLogger("tier1-echo")
-
-# Enable verbose logging for all relevant namespaces
-for ns in ["azure.ai.agentserver", "microsoft_agents", "hypercorn"]:
-    logging.getLogger(ns).setLevel(logging.DEBUG)
-
-logger.info("========== TIER1-ECHO STARTING (debug build Jun 16 2026) ==========")
-logger.info("Agent name: %s", environ.get("FOUNDRY_AGENT_NAME", "(not set)"))
-logger.info("Agent version: %s", environ.get("FOUNDRY_AGENT_VERSION", "(not set)"))
-logger.info("Session ID: %s", environ.get("FOUNDRY_AGENT_SESSION_ID", "(not set)"))
-logger.info("Port: %s", environ.get("PORT", "8088"))
-logger.info("Auth type: %s", environ.get("CONNECTIONS__SERVICE_CONNECTION__SETTINGS__AUTHTYPE", "(not set)"))
-logger.info("Client ID: %s", environ.get("CONNECTIONS__SERVICE_CONNECTION__SETTINGS__CLIENTID", "(not set)"))
-logger.info("Tenant ID: %s", environ.get("CONNECTIONS__SERVICE_CONNECTION__SETTINGS__TENANTID", "(not set)"))
-
 from azure.ai.agentserver.activity import ActivityAgentServerHost
 
 app = ActivityAgentServerHost()
 
 
 @app.activity("message")
 async def on_message(context, state):
-    """Echo the user's message back with environment variables."""
+    """Echo the user's message back."""
     user_text = context.activity.text or ""
-    logger.info("MESSAGE RECEIVED | text=%s | from=%s | conv=%s",
-                user_text[:100],
-                getattr(context.activity.from_property, "id", "?") if context.activity.from_property else "?",
-                context.activity.conversation.id if context.activity.conversation else "?")
     if user_text.strip():
-        # Build response with user message and env vars
-        env_lines = ["=== tier1echo16jun313pm ENVIRONMENT VARIABLES ==="]
-        for k, v in sorted(environ.items()):
-            env_lines.append(f"{k}={v}")
-        
-        reply = f"[Echo agent Jun 16 2026 tier1echo16jun313pm PM ]\n\nYour message: {user_text}\n\n" + "\n".join(env_lines)
+        reply = f"Echo: {user_text}"
         await context.send_activity(reply)
-        logger.info("REPLY SENT | text=%s", reply)
 
 
 @app.activity("conversationUpdate")
 async def on_members_added(context, state):
     """Welcome new members."""
     for member in context.activity.members_added or []:
         if member.id != context.activity.recipient.id:
-            logger.info("MEMBER ADDED | name=%s | id=%s", member.name, member.id)
-            try:
-                await context.send_activity(f"Welcome, {member.name}!")
-            except Exception as exc:
-                logger.warning("Could not send welcome: %s", exc)
+            await context.send_activity(f"Welcome, {member.name}!")
 
 
 @app.error
 async def on_error(context, error):
     """Handle unhandled errors."""
-    logger.error("HANDLER ERROR | error=%s", error, exc_info=True)
     await context.send_activity(f"Sorry, something went wrong: {error}")
 
 

sdk/agentserver/azure-ai-agentserver-activity/samples/multi-protocol-agent/main.py

@@ -1,26 +1,22 @@
 # Copyright (c) Microsoft. All rights reserved.
 
-"""Multi-Protocol Agent — Activity + Invocations.
+"""Multi-Protocol Agent - Activity + Invocations.
 
 Demonstrates composing Activity and Invocations protocols on a single
-server using Python mixin inheritance (Tier 2 — Builder pattern).
+server using Python mixin inheritance (Tier 2 - Builder pattern).
 
 Both protocols share the same server on port 8088:
-    POST /activity/messages  — Activity protocol (Teams/M365)
-    POST /api/messages       — Activity protocol (Bot Framework compat)
-    POST /invocations        — Invocations protocol (HTTP API)
+    POST /activity/messages  - Activity protocol (Teams/M365)
+    POST /api/messages       - Activity protocol (Bot Framework compat)
+    POST /invocations        - Invocations protocol (HTTP API)
 """
 
-import logging
-
 from starlette.requests import Request
 from starlette.responses import JSONResponse, Response
 
 from azure.ai.agentserver.activity import ActivityAgentServerHost
 from azure.ai.agentserver.invocations import InvocationAgentServerHost
 
-logging.basicConfig(level=logging.INFO, format="%(asctime)s %(levelname)s %(name)s | %(message)s")
-
 
 class MultiProtocolHost(ActivityAgentServerHost, InvocationAgentServerHost):
     pass

sdk/agentserver/azure-ai-agentserver-activity/samples/self-hosted-agent/main.py

@@ -1,6 +1,6 @@
 # Copyright (c) Microsoft. All rights reserved.
 
-"""Self-Hosted Activity Agent — Full M365 SDK Control.
+"""Self-Hosted Activity Agent - Full M365 SDK Control.
 
 Demonstrates the handler pattern (Tier 3) where the developer owns the
 full M365 Agents SDK pipeline: MsalConnectionManager, HttpAdapterBase,
@@ -12,9 +12,6 @@
 - Full control over the activity processing pipeline
 """
 
-import logging
-import sys
-import traceback
 from os import environ
 
 from starlette.responses import JSONResponse, Response
@@ -34,17 +31,10 @@
     TurnState,
 )
 
-logging.basicConfig(
-    level=logging.INFO,
-    format="%(asctime)s %(levelname)s %(name)s | %(message)s",
-)
-logger = logging.getLogger("self-hosted-agent")
-
 # ── M365 SDK setup ───────────────────────────────────────────────
 # Apply MSAL patches before creating MsalConnectionManager.
 apply_msal_patches()
 
-logger.info("Initializing M365 SDK...")
 config = load_configuration_from_env(environ)
 storage = MemoryStorage()
 connection_manager = MsalConnectionManager(**config)
@@ -57,7 +47,6 @@
     authorization=authorization,
     **config,
 )
-logger.info("M365 SDK initialized successfully.")
 
 
 # ── Business logic ───────────────────────────────────────────────
@@ -66,41 +55,30 @@
 async def on_message(context: TurnContext, state: TurnState):
     """Echo the user's message back."""
     user_text = context.activity.text or ""
-    logger.info("Message received | text=%s", user_text[:100])
     await context.send_activity(Activity(type="typing"))
     reply = f"[Self-Hosted] Echo: {user_text}"
     await context.send_activity(reply)
-    logger.info("Reply sent | text=%s", reply)
 
 
 @agent_app.activity("conversationUpdate")
 async def on_members_added(context: TurnContext, state: TurnState):
     """Welcome new members."""
     for member in context.activity.members_added or []:
         if member.id != context.activity.recipient.id:
-            try:
-                await context.send_activity(f"Welcome, {member.name}!")
-            except Exception as exc:
-                logger.warning("Could not send welcome: %s", exc)
+            await context.send_activity(f"Welcome, {member.name}!")
 
 
 @agent_app.error
 async def on_error(context: TurnContext, error: Exception):
     """Handle unhandled errors."""
-    print(f"\n [on_turn_error] unhandled error: {error}", file=sys.stderr)
-    traceback.print_exc()
     await context.send_activity("The agent encountered an error.")
 
 
 # ── Foundry host with custom handler ─────────────────────────────
 
 async def handle(request) -> Response:
-    """Bridge to M365 SDK — parses activity and delegates to agent_app."""
+    """Bridge to M365 SDK - parses activity and delegates to agent_app."""
     activity_dict = request.state.activity
-    activity_type = activity_dict.get("type", "unknown")
-    session_id = request.state.session_id
-
-    logger.info("Activity received | type=%s | session=%s", activity_type, session_id)
 
     activity = Activity.model_validate(activity_dict)
 
@@ -116,11 +94,9 @@ async def handle(request) -> Response:
         invoke_response = await adapter.process_activity(claims, activity, agent_app.on_turn)
     except PermissionError:
         return Response(status_code=401)
-    except TypeError as exc:
-        logger.warning("TypeError (likely missing serviceUrl) | error=%s", exc)
+    except TypeError:
         return Response(status_code=202)
-    except Exception as exc:
-        logger.exception("Error processing activity | error=%s", exc)
+    except Exception:
         return Response(status_code=202)
 
     if activity.type == "invoke" or activity.delivery_mode == "expectReplies":