§ )`ƒi; ãóH—dZddlmZddlmZmZmZmZGd„d¦«ZdS)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_COMPLETEDÚTASK_STATUS_FAILEDÚResultÚTaskcó®—eZdZdZdedefd„Zedefd„¦«Z edefd„¦«Z ede fd„¦«Z dd „Z d edd fd „Zd edd fd„Zdedd fd„Zd S)Ú TaskContexta— 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) ÚtaskÚstorecó0—||_||_d|_dS)NF)Ú_taskÚ_storeÚ _cancelled)Úselfr r s úy/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/mcp/shared/experimental/tasks/context.pyÚ__init__zTaskContext.__init__$s€ØˆŒ ؈Œ ؈ŒˆˆóÚreturncó—|jjS)zThe task identifier.)r ÚtaskId©rs rÚtask_idzTaskContext.task_id)s€ðŒzÔ Ð rcó—|jS)zThe current task state.)r rs rr zTaskContext.task.s €ðŒzÐrcó—|jS)z(Whether cancellation has been requested.©rrs rÚ is_cancelledzTaskContext.is_cancelled3s €ðŒÐrNcó—d|_dS)z§ Request cancellation of this task. This sets is_cancelled=True. Task work should check this periodically and exit gracefully if set. TNrrs rÚrequest_cancellationz TaskContext.request_cancellation8s€ðˆŒˆˆrÚmessagecƒóbK—|j |j|¬¦«ƒd{V—†|_dS)zn Update the task's status message. Args: message: The new status message )Ústatus_messageN)rÚ update_taskrr )rrs rÚ update_statuszTaskContext.update_statusAsPèè€ð œ;×2Ò2Ø ŒLØ"ð3ñ ô ð ð ð ð ð 𠈌 ˆ ˆ rÚresultcƒó¸K—|j |j|¦«ƒd{V—†|j |jt¬¦«ƒd{V—†|_dS)zv Mark the task as completed with the given result. Args: result: The task result N)Ústatus)rÚ store_resultrr"rr )rr$s rÚcompletezTaskContext.completeMs|èè€ðŒk×&Ò& t¤|°VÑ<Ô<Ð<Ð<Ð<Ð<Ð<Ð<Ð<Øœ;×2Ò2Ø ŒLÝ(ð3ñ ô ð ð ð ð ð 𠈌 ˆ ˆ rÚerrorcƒónK—|j |jt|¬¦«ƒd{V—†|_dS)zt Mark the task as failed with an error message. Args: error: The error message )r&r!N)rr"rrr )rr)s rÚfailzTaskContext.failZsSèè€ð œ;×2Ò2Ø ŒLÝ%Ø ð3ñ ô ð ð ð ð ð 𠈌 ˆ ˆ r)rN)Ú__name__Ú __module__Ú __qualname__Ú__doc__rrrÚpropertyÚstrrr Úboolrrr#rr(r+©rrr r s/€€€€€ððð, ˜Tð ¨)ð ð ð ð ð ð!˜ð!ð!ð!ñ„Xð!ððdðððñ„Xððð˜dðððñ„Xðððððð  ¨3ð  °4ð  ð  ð  ð  ð   Vð  °ð  ð  ð  ð  ð   ð  ¨ð  ð  ð  ð  ð  ð  rr N) r/Ú#mcp.shared.experimental.tasks.storerÚ mcp.typesrrrrr r3rrúr6sƒðððð:Ð9Ð9Ð9Ð9Ð9ØMÐMÐMÐMÐMÐMÐMÐMÐMÐMÐMÐMðX ðX ðX ðX ðX ñX ôX ðX ðX ðX r