+ wi; BRt^RIHt^RIHtHtHtHt!RR4tR#)z TaskContext - Pure task state management. This module provides TaskContext, which manages task state without any server/session dependencies. It can be used standalone for distributed workers or wrapped by ServerTaskContext for full server integration. ) TaskStore)TASK_STATUS_COMPLETEDTASK_STATUS_FAILEDResultTaskca]tRt^ toRtV3RlRlt]V3RlRl4t]V3RlRl4t]V3RlR l4t V3R lR lt V3R lR lt V3RlRlt V3RlRlt RtVtR#) TaskContextaW Pure task state management - no session dependencies. This class handles: - Task state (status, result) - Cancellation tracking - Store interactions For server-integrated features (elicit, create_message, notifications), use ServerTaskContext from mcp.server.experimental. Example (distributed worker): async def worker_job(task_id: str): store = RedisTaskStore(redis_url) task = await store.get_task(task_id) ctx = TaskContext(task=task, store=store) await ctx.update_status("Working...") result = await do_work() await ctx.complete(result) c&<V^8dQhRS[RS[/#)taskstore)rr)format __classdict__s"Y/home/ubuntu/.local/lib/python3.14/site-packages/mcp/shared/experimental/tasks/context.py __annotate__TaskContext.__annotate__$s  T ) c,WnW nRVnR#)FN)_task_store _cancelled)selfr r s&&&r__init__TaskContext.__init__$s  rc <V^8dQhRS[/#r returnstr)r rs"rrr*s!!!rc .VPP#)zThe task identifier.)rtaskIdrs&rtask_idTaskContext.task_id)szz   rc <V^8dQhRS[/#r)r)r rs"rrr/sdrc VP#)zThe current task state.)rr!s&rr TaskContext.task.szzrc <V^8dQhRS[/#r)bool)r rs"rrr4sdrc VP#)z(Whether cancellation has been requested.rr!s&r is_cancelledTaskContext.is_cancelled3src<V^8dQhRR/#)r rN)r rs"rrr8sdrc RVnR#)z Request cancellation of this task. This sets is_cancelled=True. Task work should check this periodically and exit gracefully if set. TNr*r!s&rrequest_cancellation TaskContext.request_cancellation8s rc$<V^8dQhRS[RR/#)r messagerNr)r rs"rrrAs   3  4  rc z"VPPVPVR7GRjxL VnR#L 5i)zN Update the task's status message. Args: message: The new status message )status_messageN)r update_taskr"r)rr3s&&r update_statusTaskContext.update_statusAs6 ;;22 LL"3    s +;9 ;c$<V^8dQhRS[RR/#)r resultrN)r)r rs"rrrMs   V    rc "VPPVPV4GRjxL VPPVP\R7GRjxL VnR#L>L 5i)zV Mark the task as completed with the given result. Args: result: The task result N)status)r store_resultr"r6rr)rr:s&&rcompleteTaskContext.completeMsYkk&&t||V<<<;;22 LL(3    = s!*A/A+2A/A- A/-A/c$<V^8dQhRS[RR/#)r errorrNr)r rs"rrrZs       rc "VPPVP\VR7GRjxL VnR#L 5i)zT Mark the task as failed with an error message. Args: error: The error message )r<r5N)rr6r"rr)rrAs&&rfailTaskContext.failZs9 ;;22 LL% 3    s0A> A)rrrN)__name__ __module__ __qualname____firstlineno____doc__rpropertyr"r r+r0r7r>rC__static_attributes____classdictcell__)rs@rrr sx,  !!         rrN) rI#mcp.shared.experimental.tasks.storer mcp.typesrrrrrr.rrrOs!:MMX X r