o c۷i@sdZddlmZddlmZmZmZddlmZddl m Z m Z ddl m Z mZddlmZer6ddlmZed ejd ZGd d d ZdS) u8 Experimental server session features for server→client task operations. This module provides the server-side equivalent of ExperimentalClientFeatures, allowing the server to send task-augmented requests to the client and poll for results. WARNING: These APIs are experimental and may change without notice. ) AsyncIterator) TYPE_CHECKINGAnyTypeVarN)validate_sampling_tools!validate_tool_use_result_messages)"require_task_augmented_elicitationrequire_task_augmented_sampling)poll_until_terminal) ServerSessionResultT)boundc@seZdZdZd$ddZdedejfd d Zded e e de fd d Z dede ejfddZ dddedejdedejfddZdddddddddd deejdedededBdejdBdedBdeedBdeeefdBdejdBd eejdBd!ejdBdejfd"d#ZdS)%!ExperimentalServerSessionFeaturesu Experimental server session features for server→client task operations. This provides the server-side equivalent of ExperimentalClientFeatures, allowing the server to send task-augmented requests to the client and poll for results. WARNING: These APIs are experimental and may change without notice. Access via session.experimental: result = await session.experimental.elicit_as_task(...) sessionr returnNcCs ||_dS)N)_session)selfrr^/home/ubuntu/vllm_env/lib/python3.10/site-packages/mcp/server/experimental/session_features.py__init__)s z*ExperimentalServerSessionFeatures.__init__task_idcs.|jttjtj|ddtjIdHS)z Send tasks/get to the client to get task status. Args: task_id: The task identifier Returns: GetTaskResult containing the task status taskIdparamsN)r send_requesttypes ServerRequestGetTaskRequestGetTaskRequestParams GetTaskResult)rrrrrget_task,s   z*ExperimentalServerSessionFeatures.get_task result_typecs,|jttjtj|dd|IdHS)a Send tasks/result to the client to retrieve the final result. Args: task_id: The task identifier result_type: The expected result type Returns: The task result, validated against result_type rrN)rrrrGetTaskPayloadRequestGetTaskPayloadRequestParams)rrr"rrrget_task_result;s  z1ExperimentalServerSessionFeatures.get_task_resultcCs(t|j|2z 3dHW}|Vq6dS)a Poll a client task until it reaches terminal status. Yields GetTaskResult for each poll, allowing the caller to react to status changes. Exits when task reaches a terminal status. Respects the pollInterval hint from the client. Args: task_id: The task identifier Yields: GetTaskResult for each poll N)r r!)rrstatusrrr poll_taskOsz+ExperimentalServerSessionFeatures.poll_taski`ttlmessagerequestedSchemar)c s|jjr |jjjnd}t||jttjtj||tj |dddtj IdH}|j j }| |2z3dHW}q56||tjIdHS)a Send a task-augmented elicitation to the client and poll until complete. The client will create a local task, process the elicitation asynchronously, and return the result when ready. This method handles the full flow: 1. Send elicitation with task field 2. Receive CreateTaskResult from client 3. Poll client's task until terminal 4. Retrieve and return the final ElicitResult Args: message: The message to present to the user requestedSchema: Schema defining the expected response ttl: Task time-to-live in milliseconds Returns: The client's elicitation response Raises: McpError: If client doesn't support task-augmented elicitation Nr()r*r+taskr)r client_params capabilitiesrrrr ElicitRequestElicitRequestFormParams TaskMetadataCreateTaskResultr,rr'r% ElicitResult)rr*r+r) client_caps create_resultr_rrrelicit_as_taskas(   z0ExperimentalServerSessionFeatures.elicit_as_task) r) system_promptinclude_context temperaturestop_sequencesmetadatamodel_preferencestools tool_choicemessages max_tokensr8r9r:r;r<r=r>r?c s|jjr |jjjnd} t| t| | | t||jttj tj |||||||| | | tj |dd dtj IdH} | j j}||2z3dHW}qG6||tjIdHS)a5 Send a task-augmented sampling request and poll until complete. The client will create a local task, process the sampling request asynchronously, and return the result when ready. Args: messages: The conversation messages for sampling max_tokens: Maximum tokens in the response ttl: Task time-to-live in milliseconds 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 Nr() r@ maxTokens systemPromptincludeContextr: stopSequencesr<modelPreferencesr> toolChoicer,r)rr-r.r rrrrrCreateMessageRequestCreateMessageRequestParamsr1r2r,rr'r%CreateMessageResult)rr@rAr)r8r9r:r;r<r=r>r?r4r5rr6rrrcreate_message_as_tasks<)   z8ExperimentalServerSessionFeatures.create_message_as_task)rr rN)__name__ __module__ __qualname____doc__rstrrr r!typer r%rr'ElicitRequestedSchemaintr3r7listSamplingMessageIncludeContextfloatdictrModelPreferencesTool ToolChoicerJrKrrrrrsp   8     r)rOcollections.abcrtypingrrr mcp.typesrmcp.server.validationrr*mcp.shared.experimental.tasks.capabilitiesrr %mcp.shared.experimental.tasks.pollingr mcp.server.sessionr Resultr rrrrrs