Fix additional typing issues in agentic tutorials

- Add null checks for task_state access
- Fix safe content extraction patterns
- Add null checks for span.output assignments
- Addresses reportOptionalMemberAccess errors in tutorials

Author: prassanna-ravishankar

examples/tutorials/10_agentic/00_base/020_streaming/project/acp.py

@@ -119,7 +119,7 @@ async def handle_event_send(params: SendEventParams):
 
     # Safely extract content from the task message
     response_text = ""
-    if hasattr(task_message.content, 'content'):
+    if task_message.content and hasattr(task_message.content, 'content'):
         content_val = getattr(task_message.content, 'content', '')
         if isinstance(content_val, str):
             response_text = content_val

examples/tutorials/10_agentic/00_base/030_tracing/project/acp.py

@@ -62,11 +62,19 @@ async def handle_event_send(params: SendEventParams):
     #########################################################
 
     task_state = await adk.state.get_by_task_and_agent(task_id=params.task.id, agent_id=params.agent.id)
+    if not task_state:
+        raise ValueError("Task state not found - ensure task was properly initialized")
     state = StateModel.model_validate(task_state.state)
     state.turn_number += 1
 
     # Add the new user message to the message history
-    state.messages.append(UserMessage(content=params.event.content.content))
+    # Safely extract content from the event
+    content_text = ""
+    if hasattr(params.event.content, 'content'):
+        content_val = getattr(params.event.content, 'content', '')
+        if isinstance(content_val, str):
+            content_text = content_val
+    state.messages.append(UserMessage(content=content_text))
 
     #########################################################
     # 4. (👋) Create a tracing span.
@@ -122,7 +130,13 @@ async def handle_event_send(params: SendEventParams):
             parent_span_id=span.id if span else None,
         )
 
-        state.messages.append(AssistantMessage(content=task_message.content.content))
+        # Safely extract content from the task message
+        response_text = ""
+        if task_message.content and hasattr(task_message.content, 'content'):
+            content_val = getattr(task_message.content, 'content', '')
+            if isinstance(content_val, str):
+                response_text = content_val
+        state.messages.append(AssistantMessage(content=response_text))
 
         #########################################################
         # 8. Store the messages in the task state for the next turn
@@ -144,7 +158,8 @@ async def handle_event_send(params: SendEventParams):
 
         # (👋) You can store an arbitrary pydantic model or dictionary in the span output. The idea of a span is that it easily allows you to compare the input and output of a span to see what the wrapped function did.
         # In this case, the state is comprehensive and expressive, so we just store the change in state that occured.
-        span.output = state
+        if span:
+            span.output = state
 
 @acp.on_task_cancel
 async def handle_task_cancel(params: CancelTaskParams):

examples/tutorials/10_agentic/00_base/040_other_sdks/project/acp.py

@@ -86,6 +86,8 @@ async def handle_event_send(params: SendEventParams):
 
     # Retrieve the task state. Each event is handled as a new turn, so we need to get the state for the current turn.
     task_state = await adk.state.get_by_task_and_agent(task_id=params.task.id, agent_id=params.agent.id)
+    if not task_state:
+        raise ValueError("Task state not found - ensure task was properly initialized")
     state = StateModel.model_validate(task_state.state)
     state.turn_number += 1
 
@@ -149,7 +151,8 @@ async def handle_event_send(params: SendEventParams):
         )
 
         # Set the span output to the state for the next turn
-        span.output = state
+        if span:
+            span.output = state
 
 @acp.on_task_cancel
 async def handle_task_cancel(params: CancelTaskParams):