mirror of
https://github.com/PrefectHQ/fastmcp.git
synced 2026-08-23 14:04:18 +02:00
Bump dependencies (#2931)
This commit is contained in:
parent
36876c5148
commit
71d6f49e14
8 changed files with 461 additions and 448 deletions
|
|
@ -1078,7 +1078,7 @@ class Client(Generic[ClientTransportT]):
|
|||
task_obj = ResourceTask(
|
||||
self, server_task_id, uri=str(uri), immediate_result=None
|
||||
)
|
||||
self._task_registry[server_task_id] = weakref.ref(task_obj) # type: ignore[assignment]
|
||||
self._task_registry[server_task_id] = weakref.ref(task_obj)
|
||||
return task_obj
|
||||
else:
|
||||
# Graceful degradation - server returned ReadResourceResult
|
||||
|
|
@ -1358,7 +1358,7 @@ class Client(Generic[ClientTransportT]):
|
|||
task_obj = PromptTask(
|
||||
self, server_task_id, prompt_name=name, immediate_result=None
|
||||
)
|
||||
self._task_registry[server_task_id] = weakref.ref(task_obj) # type: ignore[assignment]
|
||||
self._task_registry[server_task_id] = weakref.ref(task_obj)
|
||||
return task_obj
|
||||
else:
|
||||
# Graceful degradation - server returned GetPromptResult
|
||||
|
|
@ -1740,7 +1740,7 @@ class Client(Generic[ClientTransportT]):
|
|||
task_obj = ToolTask(
|
||||
self, server_task_id, tool_name=name, immediate_result=None
|
||||
)
|
||||
self._task_registry[server_task_id] = weakref.ref(task_obj) # type: ignore[assignment]
|
||||
self._task_registry[server_task_id] = weakref.ref(task_obj)
|
||||
return task_obj
|
||||
else:
|
||||
# Graceful degradation - server returned CallToolResult
|
||||
|
|
|
|||
|
|
@ -323,7 +323,7 @@ class FunctionPrompt(Prompt):
|
|||
return
|
||||
docket.register(self.fn, names=[self.key])
|
||||
|
||||
async def add_to_docket( # type: ignore[override]
|
||||
async def add_to_docket(
|
||||
self,
|
||||
docket: Docket,
|
||||
arguments: dict[str, Any] | None,
|
||||
|
|
|
|||
|
|
@ -429,7 +429,7 @@ class FunctionResourceTemplate(ResourceTemplate):
|
|||
return
|
||||
docket.register(self.fn, names=[self.key])
|
||||
|
||||
async def add_to_docket( # type: ignore[override]
|
||||
async def add_to_docket(
|
||||
self,
|
||||
docket: Docket,
|
||||
params: dict[str, Any],
|
||||
|
|
|
|||
|
|
@ -427,7 +427,7 @@ class FastMCPProviderResourceTemplate(ResourceTemplate):
|
|||
def register_with_docket(self, docket: Docket) -> None:
|
||||
"""No-op: the child's actual template is registered via get_tasks()."""
|
||||
|
||||
async def add_to_docket( # type: ignore[override]
|
||||
async def add_to_docket(
|
||||
self,
|
||||
docket: Docket,
|
||||
params: dict[str, Any],
|
||||
|
|
|
|||
|
|
@ -1800,9 +1800,7 @@ class FastMCP(AggregateProvider, Generic[LifespanResultT]):
|
|||
sdk_tools = [tool.to_mcp_tool(name=tool.name) for tool in tools]
|
||||
# SDK may pass None for internal cache refresh despite type hint
|
||||
cursor = (
|
||||
request.params.cursor # type: ignore[union-attr]
|
||||
if request is not None and request.params
|
||||
else None
|
||||
request.params.cursor if request is not None and request.params else None
|
||||
)
|
||||
page, next_cursor = _apply_pagination(sdk_tools, cursor, self._list_page_size)
|
||||
return mcp.types.ListToolsResult(tools=page, nextCursor=next_cursor)
|
||||
|
|
|
|||
|
|
@ -299,7 +299,7 @@ class FunctionTool(Tool):
|
|||
return
|
||||
docket.register(self.fn, names=[self.key])
|
||||
|
||||
async def add_to_docket( # type: ignore[override]
|
||||
async def add_to_docket(
|
||||
self,
|
||||
docket: Docket,
|
||||
arguments: dict[str, Any],
|
||||
|
|
|
|||
|
|
@ -1420,4 +1420,4 @@ class TestClientVersionSelection:
|
|||
|
||||
async with Client(mcp) as client:
|
||||
result = await client.read_resource("data://info", version=version)
|
||||
assert result[0].text == expected # type: ignore[union-attr]
|
||||
assert result[0].text == expected
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue