o c۷iY@sdZddlmZddlZddlmZddlmZddlm Z m Z ddl m Z ddl mZmZdd lmZdd lmZmZdd lmZdd lmZdd lmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0GdddZ1dS)z ServerTaskContext - Server-integrated task context with elicitation and sampling. This wraps the pure TaskContext and adds server-specific functionality: - Elicitation (task.elicit()) - Sampling (task.create_message()) - Status notifications )AnyN)TaskResultHandler) ServerSession)validate_sampling_tools!validate_tool_use_result_messages)McpError)"require_task_augmented_elicitationrequire_task_augmented_sampling) TaskContext) QueuedMessageTaskMessageQueue)Resolver) TaskStore)INVALID_REQUESTTASK_STATUS_INPUT_REQUIREDTASK_STATUS_WORKINGClientCapabilitiesCreateMessageResultCreateTaskResultElicitationCapabilityElicitRequestedSchema ElicitResult ErrorDataIncludeContextModelPreferences RequestIdResultSamplingCapabilitySamplingMessageServerNotificationTask TaskMetadataTaskStatusNotificationTaskStatusNotificationParamsTool ToolChoicec@s<eZdZdZdddedededededBf d d Z e d e fd d Z e d efddZ e d efddZdBddZddde ded dfddZdddeded dfddZddde ded dfddZdBd d!ZdBd"d#ZdBd$d%Zde d&ed efd'd(Zde d)e d*e d efd+d,Zddddddddd-d.eed/ed0e dBd1edBd2e dBd3ee dBd4e!e e"fdBd5e#dBd6ee$dBd7e%dBd e&fd8d9Z'd:d;de d&edZ(d:ddddddddd? d.eed/ed CallToolResult: await task.update_status("Starting...") result = await task.elicit( message="Continue?", requestedSchema={"type": "object", "properties": {"ok": {"type": "boolean"}}} ) if result.content.get("ok"): return CallToolResult(content=[TextContent(text="Done!")]) else: return CallToolResult(content=[TextContent(text="Cancelled")]) N)handlertaskstoresessionqueuer'cCs*t||d|_||_||_||_||_dS)aH Create a ServerTaskContext. Args: task: The Task object store: The task store session: The server session queue: The message queue for elicitation/sampling handler: The result handler for response routing (required for elicit/create_message) )r(r)N)r _ctx_session_queue_handler_store)selfr(r)r*r+r'r2Z/home/ubuntu/vllm_env/lib/python3.10/site-packages/mcp/server/experimental/task_context.py__init__Ms  zServerTaskContext.__init__returncC|jjS)zThe task identifier.)r,task_idr1r2r2r3r7hzServerTaskContext.task_idcCr6)zThe current task state.)r,r(r8r2r2r3r(mr9zServerTaskContext.taskcCr6)z(Whether cancellation has been requested.)r, is_cancelledr8r2r2r3r:rr9zServerTaskContext.is_cancelledcCs|jdS)z"Request cancellation of this task.N)r,request_cancellationr8r2r2r3r;wsz&ServerTaskContext.request_cancellationT)notifymessager<c.|j|IdH|r|IdHdSdS)z Update the task's status message. Args: message: The new status message notify: Whether to send a notification to the client N)r, update_status_send_notification)r1r=r<r2r2r3r?} zServerTaskContext.update_statusresultcr>)z Mark the task as completed with the given result. Args: result: The task result notify: Whether to send a notification to the client N)r,completer@)r1rBr<r2r2r3rCrAzServerTaskContext.completeerrorcr>)z Mark the task as failed with an error message. Args: error: The error message notify: Whether to send a notification to the client N)r,failr@)r1rDr<r2r2r3rErAzServerTaskContext.failc sJ|jj}|jttt|j|j|j |j |j |j |j ddIdHdS)z.Send a task status notification to the client.)taskIdstatus statusMessage createdAt lastUpdatedAtttl pollInterval)paramsN)r,r(r-send_notificationrr"r#rFrGrHrIrJrKrL)r1r(r2r2r3r@s"z$ServerTaskContext._send_notificationcC(|jttdstttdddS)z)Check if the client supports elicitation.) elicitationz.Client does not support elicitation capabilitycoder=N)r-check_client_capabilityrrrrrr8r2r2r3_check_elicitation_capabilityz/ServerTaskContext._check_elicitation_capabilitycCrO)z&Check if the client supports sampling.)samplingz+Client does not support sampling capabilityrQN)r-rSrrrrrr8r2r2r3_check_sampling_capabilityrUz,ServerTaskContext._check_sampling_capabilityrequestedSchemac s||jdurtd|jj|jtdIdH|jj|||jd}|j }t }||jj |<t d|||d}|j |j|IdHz|IdH}|jj|jtdIdHt|WStyr|jj|jtdIdHw)a Send an elicitation request via the task message queue. This method: 1. Checks client capability 2. Updates task status to "input_required" 3. Queues the elicitation request 4. Waits for the response (delivered via tasks/result round-trip) 5. Updates task status back to "working" 6. Returns the result Args: message: The message to present to the user requestedSchema: Schema defining the expected response structure Returns: The client's response Raises: McpError: If client doesn't support elicitation capability NzEhandler is required for elicit(). Pass handler= to ServerTaskContext.rG)r=rXrelated_task_idrequesttyper=resolveroriginal_request_id)rTr/ RuntimeErrorr0 update_taskr7rr-_build_elicit_form_requestidr _pending_requestsr r.enqueuewaitrrmodel_validateanyioget_cancelled_exc_class)r1r=rXr[ request_idr^queued response_datar2r2r3elicits8   zServerTaskContext.eliciturlelicitation_idc s||jdurtd|jj|jtdIdH|jj||||jd}|j }t }||jj |<t d|||d}|j |j|IdHz|IdH}|jj|jtdIdHt|WStys|jj|jtdIdHw)a Send a URL mode elicitation request via the task message queue. This directs the user to an external URL for out-of-band interactions like OAuth flows, credential collection, or payment processing. This method: 1. Checks client capability 2. Updates task status to "input_required" 3. Queues the elicitation request 4. Waits for the response (delivered via tasks/result round-trip) 5. Updates task status back to "working" 6. Returns the result Args: message: Human-readable explanation of why the interaction is needed url: The URL the user should navigate to elicitation_id: Unique identifier for tracking this elicitation Returns: The client's response indicating acceptance, decline, or cancellation Raises: McpError: If client doesn't support elicitation capability RuntimeError: If handler is not configured NzIhandler is required for elicit_url(). Pass handler= to ServerTaskContext.rY)r=rnrorZr[r\)rTr/r`r0rar7rr-_build_elicit_url_requestrcr rdr r.rerfrrrgrhri) r1r=rnror[rjr^rkrlr2r2r3 elicit_url s:   zServerTaskContext.elicit_url) system_promptinclude_context temperaturestop_sequencesmetadatamodel_preferencestools tool_choicemessages max_tokensrrrsrtrurvrwrxryc  s ||jjr|jjjnd} t| | | t||jdur#td|jj |j t dIdH|jj ||||||||| | |j d } | j } t}||jj| <td| || d}|j|j |IdHz|IdH}|jj |j tdIdHt|WSty|jj |j tdIdHw)a Send a sampling request via the task message queue. This method: 1. Checks client capability 2. Updates task status to "input_required" 3. Queues the sampling request 4. Waits for the response (delivered via tasks/result round-trip) 5. Updates task status back to "working" 6. Returns the result Args: messages: The conversation messages for sampling max_tokens: Maximum tokens in the response system_prompt: Optional system prompt include_context: Context inclusion strategy temperature: Sampling temperature stop_sequences: Stop sequences metadata: Additional metadata model_preferences: Model selection preferences tools: Optional list of tools the LLM can use during sampling tool_choice: Optional control over tool usage behavior Returns: The sampling result from the client Raises: McpError: If client doesn't support sampling capability or tools ValueError: If tool_use or tool_result message structure is invalid NzMhandler is required for create_message(). Pass handler= to ServerTaskContext.rY) rzr{rrrsrtrurvrwrxryrZr[r\)rWr- client_params capabilitiesrrr/r`r0rar7r_build_create_message_requestrcr rdr r.rerfrrrgrhri)r1rzr{rrrsrtrurvrwrxry client_capsr[rjr^rkrlr2r2r3create_messagePsN,     z ServerTaskContext.create_messagei`rKrKc sD|jjr |jjjnd}t||jdurtd|jj|jt dIdH|jj |||jt |dd}|j }t }||jj|<td|||d}|j|j|IdHz9|IdH} t| } | jj} |jj| 2z3dHW} qj6|jj| tIdH} |jj|jtdIdH| WSty|jj|jtdIdHw)aJ Send a task-augmented elicitation via the queue, then poll client. This is for use inside a task-augmented tool call when you want the client to handle the elicitation as its own task. The elicitation request is queued and delivered when the client calls tasks/result. After the client responds with CreateTaskResult, we poll the client's task until complete. Args: message: The message to present to the user requestedSchema: Schema defining the expected response structure ttl: Task time-to-live in milliseconds for the client's task Returns: The client's elicitation response Raises: McpError: If client doesn't support task-augmented elicitation RuntimeError: If handler is not configured Nz(handler is required for elicit_as_task()rYr)r=rXrZr(r[r\)r-r|r}rr/r`r0rar7rrbr!rcr rdr r.rerfrrgr(rF experimental poll_taskget_task_resultrrrhri)r1r=rXrKrr[rjr^rkrl create_resultclient_task_id_rBr2r2r3elicit_as_tasksN    z ServerTaskContext.elicit_as_task) rKrrrsrtrurvrwrxryc sh|jjr |jjjnd} t| t| | | t||jdur#td|jj |j t dIdH|jj |||||||| | | |j t |dd } | j}t}||jj|<td| ||d}|j|j |IdHz9|IdH}t|}|jj}|jj|2z3dHW}q|6|jj|tIdH}|jj |j tdIdH|WSty|jj |j tdIdHw)a< Send a task-augmented sampling request via the queue, then poll client. This is for use inside a task-augmented tool call when you want the client to handle the sampling as its own task. The request is queued and delivered when the client calls tasks/result. After the client responds with CreateTaskResult, we poll the client's task until complete. Args: messages: The conversation messages for sampling max_tokens: Maximum tokens in the response ttl: Task time-to-live in milliseconds for the client's task system_prompt: Optional system prompt include_context: Context inclusion strategy temperature: Sampling temperature stop_sequences: Stop sequences metadata: Additional metadata model_preferences: Model selection preferences tools: Optional list of tools the LLM can use during sampling tool_choice: Optional control over tool usage behavior Returns: The sampling result from the client Raises: McpError: If client doesn't support task-augmented sampling or tools ValueError: If tool_use or tool_result message structure is invalid RuntimeError: If handler is not configured Nz0handler is required for create_message_as_task()rYr) rzr{rrrsrtrurvrwrxryrZr(r[r\) r-r|r}r rrr/r`r0rar7rr~r!rcr rdr r.rerfrrgr(rFrrrrrrhri)r1rzr{rKrrrsrtrurvrwrxryrr[rjr^rkrlrrrrBr2r2r3create_message_as_tasksb,     z(ServerTaskContext.create_message_as_task)r5N)*__name__ __module__ __qualname____doc__r rrr rr4propertystrr7r(boolr:r;r?rrCrEr@rTrWrrrmrqlistrintrfloatdictrrr$r%rrrrr2r2r2r3r&5s       A J      c S     r&)2rtypingrrh+mcp.server.experimental.task_result_handlerrmcp.server.sessionrmcp.server.validationrrmcp.shared.exceptionsr*mcp.shared.experimental.tasks.capabilitiesrr %mcp.shared.experimental.tasks.contextr +mcp.shared.experimental.tasks.message_queuer r &mcp.shared.experimental.tasks.resolverr #mcp.shared.experimental.tasks.storer mcp.typesrrrrrrrrrrrrrrrrrr r!r"r#r$r%r&r2r2r2r3s       d