Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
23 changes: 10 additions & 13 deletions src/a2a/server/request_handlers/grpc_handler.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,17 +3,12 @@
import logging

from abc import ABC, abstractmethod
from collections.abc import AsyncIterable, Awaitable, Sequence
from typing import TYPE_CHECKING
from collections.abc import AsyncIterable, Awaitable


try:
import grpc
import grpc.aio

if TYPE_CHECKING:
from grpc.aio._typing import MetadataType
from grpc.aio import Metadata
except ImportError as e:
raise ImportError(
'GrpcHandler requires grpcio and grpcio-tools to be installed. '
Expand Down Expand Up @@ -56,14 +51,16 @@ def build(self, context: grpc.aio.ServicerContext) -> ServerCallContext:
def _get_metadata_value(
context: grpc.aio.ServicerContext, key: str
) -> list[str]:
md: MetadataType | None = context.invocation_metadata()
raw_values: list[str | bytes] = []
md = context.invocation_metadata()
if md is None:
return []

lower_key = key.lower()
if isinstance(md, Metadata):
raw_values = md.get_all(lower_key)
elif isinstance(md, Sequence):
raw_values = [e for (k, e) in md if k.lower() == lower_key]
return [e if isinstance(e, str) else e.decode('utf-8') for e in raw_values]
return [
e if isinstance(e, str) else e.decode('utf-8')
for k, e in md
if k.lower() == lower_key
]


class DefaultCallContextBuilder(CallContextBuilder):
Expand Down
Loading