Python: Fix source typing for pyright 1.1.410

Pyright 1.1.410 tightened several checks. Apply the same source fixes as
upstream PR microsoft#6275:

- anthropic: import AsyncAnthropicBedrock from anthropic.lib.bedrock and
  AsyncAnthropicVertex from anthropic.lib.vertex (no longer re-exported from
  the anthropic top-level package -> reportPrivateImportUsage).
- core _types.py: cast the transform-hook result to UpdateT (reportAssignmentType).
- core _workflows/_events.py: annotate the @contextmanager helper as
  Generator[None] instead of Iterator[None] (reportDeprecated).
- redis: build the combined filter expression with an explicit loop instead of
  reduce(and_, ...), which pyright could no longer fully type (drops the now
  unused functools.reduce / operator.and_ imports).

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

Author: eavanvalkenburg

python/packages/anthropic/agent_framework_anthropic/_bedrock_client.py

@@ -14,7 +14,7 @@
 from agent_framework._settings import SecretString, load_settings
 from agent_framework._telemetry import get_user_agent
 from agent_framework.observability import ChatTelemetryLayer
-from anthropic import AsyncAnthropicBedrock
+from anthropic.lib.bedrock import AsyncAnthropicBedrock
 
 from ._chat_client import AnthropicOptionsT, RawAnthropicClient
 

python/packages/anthropic/agent_framework_anthropic/_chat_client.py

@@ -31,7 +31,9 @@
 from agent_framework._tools import SHELL_TOOL_KIND_VALUE
 from agent_framework._types import _get_data_bytes_as_str  # type: ignore
 from agent_framework.observability import ChatTelemetryLayer
-from anthropic import AsyncAnthropic, AsyncAnthropicBedrock, AsyncAnthropicFoundry, AsyncAnthropicVertex
+from anthropic import AsyncAnthropic, AsyncAnthropicFoundry
+from anthropic.lib.bedrock import AsyncAnthropicBedrock
+from anthropic.lib.vertex import AsyncAnthropicVertex
 from anthropic.types.beta import (
     BetaContentBlock,
     BetaMessage,

python/packages/anthropic/agent_framework_anthropic/_vertex_client.py

@@ -14,7 +14,8 @@
 from agent_framework._settings import load_settings
 from agent_framework._telemetry import get_user_agent
 from agent_framework.observability import ChatTelemetryLayer
-from anthropic import NOT_GIVEN, AsyncAnthropicVertex
+from anthropic import NOT_GIVEN
+from anthropic.lib.vertex import AsyncAnthropicVertex
 
 from ._chat_client import AnthropicOptionsT, RawAnthropicClient
 

python/packages/core/agent_framework/_types.py

@@ -3136,7 +3136,7 @@ async def __anext__(self) -> UpdateT:
             if isawaitable(hooked):
                 hooked = await hooked
             if hooked is not None:
-                update = hooked
+                update = cast(UpdateT, hooked)
         return update
 
     async def _resolve_stream_with_pull_contexts(self) -> AsyncIterable[UpdateT]:

python/packages/core/agent_framework/_workflows/_events.py

@@ -6,7 +6,7 @@
 import sys
 import traceback as _traceback
 import warnings
-from collections.abc import Iterator
+from collections.abc import Generator
 from contextlib import contextmanager
 from contextvars import ContextVar
 from dataclasses import dataclass
@@ -46,7 +46,7 @@ def _current_event_origin() -> WorkflowEventSource:
 
 
 @contextmanager
-def _framework_event_origin() -> Iterator[None]:  # pyright: ignore[reportUnusedFunction]
+def _framework_event_origin() -> Generator[None]:  # pyright: ignore[reportUnusedFunction]
     """Temporarily mark subsequently created events as originating from the framework (internal)."""
     token = _event_origin_context.set(WorkflowEventSource.FRAMEWORK)
     try:

python/packages/redis/agent_framework_redis/_context_provider.py

@@ -10,8 +10,6 @@
 
 import json
 import sys
-from functools import reduce
-from operator import and_
 from typing import TYPE_CHECKING, Any, ClassVar, Literal
 
 import numpy as np
@@ -191,7 +189,12 @@ def schema_dict(self) -> dict[str, Any]:
     def _build_filter_from_dict(self, filters: dict[str, str | None]) -> Any | None:
         """Builds a combined filter expression from simple equality tags."""
         parts: list[FilterExpression] = [Tag(k) == v for k, v in filters.items() if v]
-        return reduce(and_, parts) if parts else None
+        if not parts:
+            return None
+        combined = parts[0]
+        for part in parts[1:]:
+            combined = combined & part
+        return combined
 
     def _build_schema_dict(
         self,