i'* dZddlmZmZddlmZmZmZddlm Z ddl m Z ddl m Z ddlmZerddlmZGd d eZGd d eZGd deZGddeZGddeZGddeZde defde j0de j2e j4zfdZde defde j8de j:e j4zfdZde defde j>dzde j@e j4zfdZ!de defde jDde jFe j4zfdZ$de defde jJde jLde jNe j4zfdZ(de defde jRde jLde jNe j4zfdZ*eGd d!Z+e(Z,e*Z-y)"a Experimental task handler protocols for server -> client requests. This module provides Protocol types and default handlers for when servers send task-related requests to clients (the reverse of normal client -> server flow). WARNING: These APIs are experimental and may change without notice. Use cases: - Server sends task-augmented sampling/elicitation request to client - Client creates a local task, spawns background work, returns CreateTaskResult - Server polls client's task status via tasks/get, tasks/result, etc. ) dataclassfield) TYPE_CHECKINGAnyProtocol) TypeAdapterN)RequestContext)RequestResponder) ClientSessioncpeZdZdZdedefdejdejejzfdZ y)GetTaskHandlerFnTzrHandler for tasks/get requests from server. WARNING: This is experimental and may change without notice. contextr paramsreturnc KywNselfrrs e/root/aria/mcps/aria-brain/venv/lib/python3.12/site-packages/mcp/client/experimental/task_handlers.py__call__zGetTaskHandlerFnT.__call__"s 14N) __name__ __module__ __qualname____doc__r rtypesGetTaskRequestParams GetTaskResult ErrorDatarrrr r sG 4 454**4   u . 4r!r cpeZdZdZdedefdejdejejzfdZ y)GetTaskResultHandlerFnTzuHandler for tasks/result requests from server. WARNING: This is experimental and may change without notice. rr rrc Kywrrrs rrz GetTaskResultHandlerFnT.__call__/s 8;rN) rrrrr rrGetTaskPayloadRequestParamsGetTaskPayloadResultr rrr!rr#r#)sG ; 45;11;  # #eoo 5 ;r!r#cveZdZdZdedefdejdzdejejzfdZ y)ListTasksHandlerFnTzsHandler for tasks/list requests from server. WARNING: This is experimental and may change without notice. rr rNrc Kywrrrs rrzListTasksHandlerFnT.__call__<s 36r) rrrrr rrPaginatedRequestParamsListTasksResultr rrr!rr(r(6sL 6 456,,t36    0 6r!r(cpeZdZdZdedefdejdejejzfdZ y)CancelTaskHandlerFnTzuHandler for tasks/cancel requests from server. WARNING: This is experimental and may change without notice. rr rrc Kywrrrs rrzCancelTaskHandlerFnT.__call__Is 47rN) rrrrr rrCancelTaskRequestParamsCancelTaskResultr rrr!rr-r-CsG 7 457--7   %// 1 7r!r-c eZdZdZdedefdejdejdejejzfdZ y) TaskAugmentedSamplingFnTaRHandler for task-augmented sampling/createMessage requests from server. When server sends a CreateMessageRequest with task field, this callback is invoked. The callback should create a task, spawn background work, and return CreateTaskResult immediately. WARNING: This is experimental and may change without notice. rr r task_metadatarc Kywrrrrrr3s rrz!TaskAugmentedSamplingFnT.__call__Z 47rN) rrrrr rrCreateMessageRequestParams TaskMetadataCreateTaskResultr rrr!rr2r2PsW7 457007)) 7   %// 1 7r!r2c eZdZdZdedefdejdejdejejzfdZ y) TaskAugmentedElicitationFnTaHHandler for task-augmented elicitation/create requests from server. When server sends an ElicitRequest with task field, this callback is invoked. The callback should create a task, spawn background work, and return CreateTaskResult immediately. WARNING: This is experimental and may change without notice. rr rr3rc Kywrrr5s rrz$TaskAugmentedElicitationFnT.__call__lr6rN) rrrrr rrElicitRequestParamsr8r9r rrr!rr;r;bsW7 457))7)) 7   %// 1 7r!r;rr rrcTKtjtjdSw)Nztasks/get not supportedcodemessagerr METHOD_NOT_FOUNDrrs rdefault_get_task_handlerrEts% ??  # #) &(cTKtjtjdSw)Nztasks/result not supportedr?rBrDs rdefault_get_task_result_handlerrH~% ??  # #, rFcTKtjtjdSw)Nztasks/list not supportedr?rBrDs rdefault_list_tasks_handlerrKs% ??  # #* rFcTKtjtjdSw)Nztasks/cancel not supportedr?rBrDs rdefault_cancel_task_handlerrMrIrFr3cTKtjtjdSw)Nz%Task-augmented sampling not supportedr?rr INVALID_REQUESTrrr3s rdefault_task_augmented_samplingrRs% ??  " "7 rFcTKtjtjdSw)Nz(Task-augmented elicitation not supportedr?rOrQs r"default_task_augmented_elicitationrTs% ??  " ": rFc^eZdZUdZeeZeed<ee Z e ed<ee Z eed<eeZeed<eeZeed<eeZeed<d ej2d zfd Zed ej8d efd Zdede fde!ej8ejDfd d fdZ#y )ExperimentalTaskHandlersaBContainer for experimental task handlers. Groups all task-related handlers that handle server -> client requests. This includes both pure task requests (get, list, cancel, result) and task-augmented request handlers (sampling, elicitation with task field). WARNING: These APIs are experimental and may change without notice. Example: handlers = ExperimentalTaskHandlers( get_task=my_get_task_handler, list_tasks=my_list_tasks_handler, ) session = ClientSession(..., experimental_task_handlers=handlers) )defaultget_taskget_task_result list_tasks cancel_taskaugmented_samplingaugmented_elicitationrNc(|jtu}|jtu}|jt u}|j tu}t||||gsyd}|s|rktj|r(tjtjnd|r(tjtjnd}tj|rtj nd|rtj"|Sd|S)a4Build ClientTasksCapability from the configured handlers. Returns a capability object that reflects which handlers are configured (i.e., not using the default "not supported" handlers). Returns: ClientTasksCapability if any handlers are provided, None otherwise N) createMessage)create)sampling elicitation)listcancelrequests)rZrKr[rMr\rRr]rTanyrClientTasksRequestsCapabilityTasksSamplingCapabilityTasksCreateMessageCapabilityTasksElicitationCapability TasksCreateElicitationCapabilityClientTasksCapabilityTasksListCapabilityTasksCancelCapability)rhas_list has_cancel has_samplinghas_elicitationrequests_capabilitys rbuild_capabilityz)ExperimentalTaskHandlers.build_capabilitys??*DD%%-HH ..6UU 44<^^Hj,HIKO ?"'"E"E66UEgEgEij""<5..0(  DH(  r!requestct|jtjtjztj ztj zS)z5Check if this handler handles the given request type.) isinstancerootrGetTaskRequestGetTaskPayloadRequestListTasksRequestCancelTaskRequest)rus rhandles_requestz(ExperimentalTaskHandlers.handles_requestsC LL  5#>#> >AWAW WZ_ZqZq q  r!ctxr respondercKttjtjz}|jj xtj dxI\}|j||d{}|j|}|j|d{yxtjdxI\}|j||d{}|j|}|j|d{yxtjdxI\}|j||d{}|j|}|j|d{ytjdxH\}|j||d{}|j|}|j|d{y t!dt#|jj 7u7N77777k7Cw)zHandle a task-related request from the server. Call handles_request() first to check if this handler can handle the request. )rNzUnhandled request type: )rr ClientResultr rurxryrXvalidate_pythonrespondrzrYr{rZr|r[ ValueErrortype)rr~rclient_response_typerresponseclient_responses rhandle_requestz'ExperimentalTaskHandlers.handle_requestsS^    0S $$4%%4!%sF!;;"6"F"Fx"P''8885 <,,;!%!5!5c6!BB"6"F"Fx"P''888< 7''6!%f!=="6"F"Fx"P''8887 ((7!%!1!1#v!>>"6"F"Fx"P''8888  #;DARARAWAW8?8sA-G7/G$0)G7G'3G7 G*)G77G-83G7+G/,)G7G11G7G3)G71G523G7'G7*G7-G7/G71G73G75G7)$rrrrrrErXr __annotations__rHrYr#rKrZr(rMr[r-rRr\r2rTr]r;rrlrt staticmethod ServerRequestboolr}r rr rrrr!rrVrVs"#(0H"IHI/4=\/]O,]&+4N&OJ#O(-6Q(RK%R49A`3a0a9>Gi9j6j" %"="="D" H !4!4   #\ OS0 1#\$E$7$79K9K$KL#\  #\r!rV).r dataclassesrrtypingrrrpydanticr mcp.typesrmcp.shared.contextr mcp.shared.sessionr mcp.client.sessionr r r#r(r-r2r;rrr rEr%r&rHr*r+rKr/r0rMr7r8r9rRr=rTrV(default_task_augmented_sampling_callback+default_task_augmented_elicitation_callbackrr!rrs7 )// -/0 4 4 ;h ; 6( 6 78 77x7$7(7$ OS0 1  & & 5??* OS0 1  - - %//1 OS0 1  ( (4 / U__, OS0 1  ) ) eoo- OS0 1  , ,%% eoo-  OS0 1  % %%% eoo-  j\j\ j\\,K(.P+r!