Fix content type extraction in temporal state machine tutorials

- Add safe content extraction patterns for TaskMessageContent unions
- Replace direct .content access with hasattr/getattr patterns
- Addresses str | List[str] | Unknown | object | None type errors

Author: prassanna-ravishankar

examples/tutorials/10_agentic/10_temporal/020_state_machine/project/workflow.py

@@ -72,7 +72,13 @@ async def on_task_event_send(self, params: SendEventParams) -> None:
                 # Check if we're in the middle of follow-up questions
                 if deep_research_data.n_follow_up_questions_to_ask > 0:
                     # User is responding to a follow-up question
-                    deep_research_data.follow_up_responses.append(message.content)
+                    # Safely extract content from message
+                    content_text = ""
+                    if hasattr(message, 'content'):
+                        content_val = getattr(message, 'content', '')
+                        if isinstance(content_val, str):
+                            content_text = content_val
+                    deep_research_data.follow_up_responses.append(content_text)
 
                     # Add the Q&A to the agent input list as context
                     if deep_research_data.follow_up_questions:
@@ -115,11 +121,18 @@ async def on_task_event_send(self, params: SendEventParams) -> None:
             await self.state_machine.transition(DeepResearchState.CLARIFYING_USER_QUERY)
 
         # Echo back the user's message
+        # Safely extract content from message for display
+        message_content = ""
+        if hasattr(message, 'content'):
+            content_val = getattr(message, 'content', '')
+            if isinstance(content_val, str):
+                message_content = content_val
+
         await adk.messages.create(
             task_id=task.id,
             content=TextContent(
                 author="user",
-                content=message.content,
+                content=message_content,
             ),
             trace_id=task.id,
             parent_span_id=deep_research_data.current_span.id if deep_research_data.current_span else None,

examples/tutorials/10_agentic/10_temporal/020_state_machine/project/workflows/deep_research/clarify_user_query.py

@@ -68,7 +68,12 @@ async def execute(self, state_machine: StateMachine, state_machine_data: Optiona
                 trace_id=state_machine_data.task_id,
                 parent_span_id=state_machine_data.current_span.id,
             )
-            follow_up_question = task_message.content.content
+            # Safely extract content from task message
+            follow_up_question = ""
+            if task_message.content and hasattr(task_message.content, 'content'):
+                content_val = getattr(task_message.content, 'content', '')
+                if isinstance(content_val, str):
+                    follow_up_question = content_val
 
             # Update with follow-up question
             state_machine_data.follow_up_questions.append(follow_up_question)