Reverting some changes

Author: IdkwhatImD0ing

examples/tutorials/10_agentic/10_temporal/000_hello_acp/project/workflow.py

@@ -33,7 +33,8 @@ def __init__(self):
     @workflow.signal(name=SignalName.RECEIVE_EVENT)
     @override
     async def on_task_event_send(self, params: SendEventParams) -> None:
-            
+        logger.info(f"Received task message instruction: {params}")
+
         # 2. Echo back the client's message to show it in the UI. This is not done by default so the agent developer has full control over what is shown to the user.
         await adk.messages.create(task_id=params.task.id, content=params.event.content)
 

examples/tutorials/10_agentic/10_temporal/010_agent_chat/project/workflow.py

@@ -163,6 +163,7 @@ def __init__(self):
     @workflow.signal(name=SignalName.RECEIVE_EVENT)
     @override
     async def on_task_event_send(self, params: SendEventParams) -> None:
+        logger.info(f"Received task message instruction: {params}")
 
         if not params.event.content:
             return
@@ -242,7 +243,6 @@ async def on_task_event_send(self, params: SendEventParams) -> None:
                 ),
                 # tools=[CALCULATOR_TOOL],
             )
-            # Response is finished from agent
             if self._state:
                 # Update the state with the final input list if available
                 final_list = getattr(run_result, "final_input_list", None)

examples/tutorials/10_agentic/10_temporal/050_agent_chat_guardrails/pyproject.toml

@@ -9,7 +9,7 @@ description = "An AgentEx agentthat streams multiturn tool-enabled chat with tra
 readme = "README.md"
 requires-python = ">=3.12"
 dependencies = [
-    "agentex-sdk @ file://../../../../../",
+    "agentex-sdk",
     "debugpy>=1.8.15",
     "scale-gp",
 ]
@@ -22,9 +22,6 @@ dev = [
     "flake8",
 ]
 
-[tool.hatch.metadata]
-allow-direct-references = true
-
 [tool.hatch.build.targets.wheel]
 packages = ["project"]
 

src/agentex/lib/core/services/adk/streaming.py

@@ -208,8 +208,6 @@ async def open(self) -> "StreamingTaskMessageContext":
 
         return self
 
-
-
     async def close(self) -> TaskMessage:
         """Close the streaming context."""
         if not self.task_message:

src/agentex/lib/utils/dev_tools/async_messages.py

@@ -332,7 +332,6 @@ def subscribe_to_async_task_messages(
                             # Deserialize the discriminated union TaskMessageUpdate based on the "type" field
                             message_type = task_message_update_data.get("type", "unknown")
 
-                            
                             # Handle different message types for streaming progress
                             if message_type == "start":
                                 task_message_update = StreamTaskMessageStart.model_validate(task_message_update_data)