Fix remaining linting issues

- Replace bare except with Exception (E722)
- Fix unused loop variable in notebook by using actual event_message
- Replace blind Exception assert with specific exceptions (B017)

Author: prassanna-ravishankar

examples/tutorials/10_agentic/00_base/080_batch_events/dev.ipynb

@@ -50,59 +50,7 @@
    "id": "3",
    "metadata": {},
    "outputs": [],
-   "source": [
-    "# Send an event to the agent\n",
-    "from agentex.types import Event\n",
-    "from agentex.types.agent_rpc_params import ParamsSendEventRequest\n",
-    "\n",
-    "# The response is expected to be a list of TaskMessage objects, which is a union of the following types:\n",
-    "# - TextContent: A message with just text content   \n",
-    "# - DataContent: A message with JSON-serializable data content\n",
-    "# - ToolRequestContent: A message with a tool request, which contains a JSON-serializable request to call a tool\n",
-    "# - ToolResponseContent: A message with a tool response, which contains response object from a tool call in its content\n",
-    "\n",
-    "# When processing the message/send response, if you are expecting more than TextContent, such as DataContent, ToolRequestContent, or ToolResponseContent, you can process them as well\n",
-    "\n",
-    "concurrent_event_messages: list[ParamsSendEventRequest] = [\n",
-    "    {\n",
-    "        \"content\": {\"type\": \"text\", \"author\": \"user\", \"content\": \"Hello, what can you do?\"},\n",
-    "        \"task_id\": task.id,\n",
-    "    },\n",
-    "    {\n",
-    "        \"content\": {\"type\": \"text\", \"author\": \"user\", \"content\": \"Can you tell me a joke?\"},\n",
-    "        \"task_id\": task.id,\n",
-    "    },\n",
-    "    {\n",
-    "        \"content\": {\"type\": \"text\", \"author\": \"user\", \"content\": \"What is the capital of France?\"},\n",
-    "        \"task_id\": task.id,\n",
-    "    },\n",
-    "    {\n",
-    "        \"content\": {\"type\": \"text\", \"author\": \"user\", \"content\": \"Write a short story about a cat\"},\n",
-    "        \"task_id\": task.id,\n",
-    "    },\n",
-    "    {\n",
-    "        \"content\": {\"type\": \"text\", \"author\": \"user\", \"content\": \"Tell me how an LLM works\"},\n",
-    "        \"task_id\": task.id,\n",
-    "    },\n",
-    "]\n",
-    "\n",
-    "events: list[Event] = []\n",
-    "\n",
-    "for event_message in concurrent_event_messages:\n",
-    "    rpc_response = client.agents.send_event(\n",
-    "        agent_name=AGENT_NAME,\n",
-    "        params={\n",
-    "            \"content\": {\"type\": \"text\", \"author\": \"user\", \"content\": \"Hello tell me the latest news about AI and AI startups\"},\n",
-    "            \"task_id\": task.id,\n",
-    "        }\n",
-    "    )\n",
-    "\n",
-    "    event = rpc_response.result\n",
-    "    events.append(event)\n",
-    "\n",
-    "for event in events:\n",
-    "    print(event)"
-   ]
+   "source": "from agentex.lib.utils.dev_tools import subscribe_to_async_task_messages\nfrom agentex.types import Event\nfrom agentex.types.agent_rpc_params import ParamsSendEventRequest\n\n# The response is expected to be a list of TaskMessage objects, which is a union of the following types:\n# - TextContent: A message with just text content   \n# - DataContent: A message with JSON-serializable data content\n# - ToolRequestContent: A message with a tool request, which contains a JSON-serializable request to call a tool\n# - ToolResponseContent: A message with a tool response, which contains response object from a tool call in its content\n\n# When processing the message/send response, if you are expecting more than TextContent, such as DataContent, ToolRequestContent, or ToolResponseContent, you can process them as well\n\nconcurrent_event_messages: list[ParamsSendEventRequest] = [\n    {\n        \"content\": {\"type\": \"text\", \"author\": \"user\", \"content\": \"Hello, what can you do?\"},\n        \"task_id\": task.id,\n    },\n    {\n        \"content\": {\"type\": \"text\", \"author\": \"user\", \"content\": \"Can you tell me a joke?\"},\n        \"task_id\": task.id,\n    },\n    {\n        \"content\": {\"type\": \"text\", \"author\": \"user\", \"content\": \"What is the capital of France?\"},\n        \"task_id\": task.id,\n    },\n    {\n        \"content\": {\"type\": \"text\", \"author\": \"user\", \"content\": \"Write a short story about a cat\"},\n        \"task_id\": task.id,\n    },\n    {\n        \"content\": {\"type\": \"text\", \"author\": \"user\", \"content\": \"Tell me how an LLM works\"},\n        \"task_id\": task.id,\n    },\n]\n\nevents: list[Event] = []\n\nfor event_message in concurrent_event_messages:\n    rpc_response = client.agents.send_event(\n        agent_name=AGENT_NAME,\n        params=event_message\n    )\n\n    event = rpc_response.result\n    events.append(event)\n\nfor event in events:\n    print(event)"
   },
   {
    "cell_type": "code",
@@ -153,4 +101,4 @@
  },
  "nbformat": 4,
  "nbformat_minor": 5
-}
+}

examples/tutorials/10_agentic/10_temporal/030_custom_activities/project/workflow_utils.py

@@ -37,7 +37,7 @@ async def dequeue_pending_data(queue: asyncio.Queue[Any], data_to_process: List[
                 item = queue.get_nowait()
                 data_to_process.append(item)
                 items_dequeued += 1
-            except:
+            except Exception:
                 # Queue became empty while we were dequeuing
                 break
 

tests/test_function_tool.py

@@ -2,6 +2,7 @@
 from typing import Any
 
 import pytest
+from pydantic import ValidationError
 
 from src.agentex.lib.core.temporal.activities.adk.providers.openai_activities import (
     FunctionTool,
@@ -225,7 +226,7 @@ def test_deserialization_error_handling(self):
         )
 
         # This should raise an error during model validation due to invalid base64
-        with pytest.raises(Exception):  # Could be ValidationError or ValueError
+        with pytest.raises((ValidationError, ValueError)):
             FunctionTool.model_validate(serialized_data)
 
     def test_full_roundtrip_with_serialization(self):