chore(types): delete five type: ignore comments that suppress nothing
mypy's warn_unused_ignores is on, so these were reported as errors in their own right — a suppression that no longer suppresses is a claim that something is broken when it is not, and it silently widens to cover a real error if one later appears on that line. Two carried a "Forward reference" note that is still accurate; the note is kept and only the ignore removed. 95 errors -> 90. Comment-only, so no runtime behaviour can have changed and the suite was not re-run for this commit. The `# type: ignore` count across the tree drops from 6 to 1, which is the anchor for the rest of this work: clearing a type error by suppressing it would push that number the other way. Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
@@ -71,7 +71,7 @@ class FunctionCallOutputItem(CustomBaseModel):
|
|||||||
|
|
||||||
# Union type for all output items
|
# Union type for all output items
|
||||||
# Type: ignore because Pydantic handles union types specially
|
# Type: ignore because Pydantic handles union types specially
|
||||||
OutputItem = MessageOutputItem | ReasoningOutputItem | FunctionCallOutputItem # type: ignore
|
OutputItem = MessageOutputItem | ReasoningOutputItem | FunctionCallOutputItem
|
||||||
|
|
||||||
|
|
||||||
# ============================================================================
|
# ============================================================================
|
||||||
|
|||||||
@@ -137,7 +137,7 @@ class StreamingCoordinator:
|
|||||||
|
|
||||||
async def stream_response_with_steward(
|
async def stream_response_with_steward(
|
||||||
self,
|
self,
|
||||||
request: "ResponseRequest", # type: ignore # Forward reference
|
request: "ResponseRequest", # Forward reference
|
||||||
) -> AsyncGenerator[StreamEvent, None]:
|
) -> AsyncGenerator[StreamEvent, None]:
|
||||||
"""
|
"""
|
||||||
Stream response with Steward preprocessing and two-phase Tatlock execution.
|
Stream response with Steward preprocessing and two-phase Tatlock execution.
|
||||||
@@ -282,8 +282,8 @@ class StreamingCoordinator:
|
|||||||
async def _stream_direct_delegation(
|
async def _stream_direct_delegation(
|
||||||
self,
|
self,
|
||||||
user_message: str,
|
user_message: str,
|
||||||
recommendation: "StewardRecommendation", # type: ignore
|
recommendation: "StewardRecommendation",
|
||||||
tracker: "ToolCallTracker", # type: ignore
|
tracker: "ToolCallTracker",
|
||||||
conversation_id: str,
|
conversation_id: str,
|
||||||
conversation_history: list | None = None,
|
conversation_history: list | None = None,
|
||||||
results: dict | None = None,
|
results: dict | None = None,
|
||||||
@@ -387,7 +387,7 @@ class StreamingCoordinator:
|
|||||||
|
|
||||||
async def stream_response(
|
async def stream_response(
|
||||||
self,
|
self,
|
||||||
request: "ResponseRequest", # type: ignore # Forward reference
|
request: "ResponseRequest", # Forward reference
|
||||||
) -> AsyncGenerator[StreamEvent, None]:
|
) -> AsyncGenerator[StreamEvent, None]:
|
||||||
"""
|
"""
|
||||||
Coordinate streaming from agent to SSE events.
|
Coordinate streaming from agent to SSE events.
|
||||||
|
|||||||
Reference in New Issue
Block a user