+ wiRt^RIHt^RIHt^RIHtHt^RIHt^RI H t ^RI H t ^RI Ht^RIHtHtHtHtHtHtHtHtHtHtR tR tR R ltR RltRRltRRRllt]RRl4t R#)z Helper functions for pure task management. These helpers work with pure TaskContext and don't require server dependencies. For server-integrated task helpers, use mcp.server.experimental. ) AsyncIterator)asynccontextmanager)datetimetimezone)uuid4)McpError) TaskContext) TaskStore) INVALID_PARAMSTASK_STATUS_CANCELLEDTASK_STATUS_COMPLETEDTASK_STATUS_FAILEDTASK_STATUS_WORKINGCancelTaskResult ErrorDataTask TaskMetadata TaskStatusz0io.modelcontextprotocol/model-immediate-responsez$io.modelcontextprotocol/related-taskc0V^8dQhR\R\/#)statusreturn)rbool)formats"Y/home/ubuntu/.local/lib/python3.14/site-packages/mcp/shared/experimental/tasks/helpers.py __annotate__r&s X X Xt Xc*V\\\39#)z Check if a task status represents a terminal state. Terminal states are those where the task has finished and will not change. Args: status: The task status to check Returns: True if the status is terminal (completed, failed, or cancelled) )r r r rs&r is_terminalr&s +-?AVW WWrc<V^8dQhR\R\R\/#)rstoretask_idr)r strr)rs"rrr5s&1;1; 1; 1;1;rc|"VPV4GRjxL pVf\\\RV 2R74h\ VP 4'd)\\\RVP R2R74hVP V\R7GRjxL p\R/VP4B#LL5i)a Cancel a task with spec-compliant validation. Per spec: "Receivers MUST reject cancellation of terminal status tasks with -32602 (Invalid params)" This helper validates that the task exists and is not in a terminal state before setting it to "cancelled". Args: store: The task store task_id: The task identifier to cancel Returns: CancelTaskResult with the cancelled task state Raises: McpError: With INVALID_PARAMS (-32602) if: - Task does not exist - Task is already in a terminal state (completed, failed, cancelled) Example: @server.experimental.cancel_task() async def handle_cancel(request: CancelTaskRequest) -> CancelTaskResult: return await cancel_task(store, request.params.taskId) NzTask not found: )codemessagez&Cannot cancel task in terminal state ''r) get_taskrrr rr update_taskr r model_dump)r!r"taskcancelled_tasks&& r cancel_taskr.5s<( (D | #*7)4   4;; #@ QO   !,,W=R,SSN  :n779 ::' )$Ts"B<B8BB<B:B<:B<c$V^8dQhR\/#)rr)r#)rs"rrris#rc(\\44#)zGenerate a unique task ID.)r#rr(rrgenerate_task_idr1is uw<rNcJV^8dQhR\R\R,R\/#)rmetadatar"Nr)rr#r)rs"rrrns* 4Z rc \P!\P4p\ T;'g \ 4\ VVVPRR7#)z Create a Task object with initial state. This is a helper for TaskStore implementations. Args: metadata: Task metadata task_id: Optional task ID (generated if not provided) Returns: A new Task in "working" status i)taskIdr createdAt lastUpdatedAtttl pollInterval)rnowrutcrr1rr8)r3r"r:s&& rcreate_task_stater<nsE ,,x|| $C ,,*," LL  rcRV^8dQhR\R\R\\,/#)rr"r!r)r#r rr)rs"rrrs+*#*# *# *#;*#rcZ"VPV4GRjxL pVf\RV R24h\W!4pV5xR#L* \dZp\ TP P 4'g*TP\T44GRjxL Rp?R#Rp?R#Rp?ii;i5i)a Context manager for safe task execution (pure, no server dependencies). Loads a task from the store and provides a TaskContext for the work. If an unhandled exception occurs, the task is automatically marked as failed and the exception is suppressed (since the failure is captured in task state). This is useful for distributed workers that don't have a server session. Args: task_id: The task identifier to execute store: The task store (must be accessible by the worker) Yields: TaskContext for updating status and completing/failing the task Raises: ValueError: If the task is not found in the store Example (distributed worker): async def worker_process(task_id: str): store = RedisTaskStore(redis_url) async with task_execution(task_id, store) as ctx: await ctx.update_status("Working...") result = await do_work() await ctx.complete(result) NzTask z not found) r) ValueErrorr Exceptionrr,rfailr#)r"r!r,ctxes&& rtask_executionrDs@( (D |5 455 d "C# ) #388??++((3q6" " ",#sEB+A"B+AB+ B(AB#BB# B+#B((B+)N)!__doc__collections.abcr contextlibrrruuidrmcp.shared.exceptionsr%mcp.shared.experimental.tasks.contextr#mcp.shared.experimental.tasks.storer mcp.typesr r r r rrrrrrMODEL_IMMEDIATE_RESPONSE_KEYRELATED_TASK_METADATA_KEYrr.r1r<rDr(rrrOsl**'*=9    RC X1;h 6*#*#r