Skip to content

Commit 5fd17d1

Browse files
committed
fix: resolve pyright errors in ExperimentalHandlers.enable_tasks
1 parent 7801dc3 commit 5fd17d1

File tree

1 file changed

+7
-4
lines changed

1 file changed

+7
-4
lines changed

src/mcp/server/lowlevel/experimental.py

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -129,6 +129,7 @@ def enable_tasks(
129129
queue = InMemoryTaskMessageQueue()
130130

131131
self._task_support = TaskSupport(store=store, queue=queue)
132+
task_support = self._task_support
132133

133134
# Register user-provided handlers
134135
if on_get_task is not None:
@@ -144,7 +145,7 @@ def enable_tasks(
144145
if not self._has_handler("tasks/get"):
145146

146147
async def _default_get_task(ctx: ServerRequestContext[LifespanResultT], params: GetTaskRequestParams) -> GetTaskResult:
147-
task = await self._task_support.store.get_task(params.task_id)
148+
task = await task_support.store.get_task(params.task_id)
148149
if task is None:
149150
raise MCPError(code=INVALID_PARAMS, message=f"Task not found: {params.task_id}")
150151
return GetTaskResult(
@@ -166,7 +167,7 @@ async def _default_get_task_result(
166167
) -> GetTaskPayloadResult:
167168
assert ctx.request_id is not None
168169
req = GetTaskPayloadRequest(params=params)
169-
result = await self._task_support.handler.handle(req, ctx.session, ctx.request_id)
170+
result = await task_support.handler.handle(req, ctx.session, ctx.request_id)
170171
return result
171172

172173
self._add_request_handler("tasks/result", _default_get_task_result)
@@ -177,7 +178,7 @@ async def _default_list_tasks(
177178
ctx: ServerRequestContext[LifespanResultT], params: PaginatedRequestParams | None
178179
) -> ListTasksResult:
179180
cursor = params.cursor if params else None
180-
tasks, next_cursor = await self._task_support.store.list_tasks(cursor)
181+
tasks, next_cursor = await task_support.store.list_tasks(cursor)
181182
return ListTasksResult(tasks=tasks, next_cursor=next_cursor)
182183

183184
self._add_request_handler("tasks/list", _default_list_tasks)
@@ -187,7 +188,9 @@ async def _default_list_tasks(
187188
async def _default_cancel_task(
188189
ctx: ServerRequestContext[LifespanResultT], params: CancelTaskRequestParams
189190
) -> CancelTaskResult:
190-
result = await cancel_task(self._task_support.store, params.task_id)
191+
result = await cancel_task(task_support.store, params.task_id)
191192
return result
192193

193194
self._add_request_handler("tasks/cancel", _default_cancel_task)
195+
196+
return task_support

0 commit comments

Comments
 (0)