+ Q(i&L6Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RIH t H t ^RI H t H t ^RI HtHtHt^RIt^RIHtHt^RIHtHt^RIHt]!]4t]'d ^R IHtHt!R R ]4t]!R 4t !R R]PB]] ,4t"!RR]"R,4t#!RR]"]PHPJ,4t&!RR]"]']PHPP]PHPR,,,4t*R#)zSEP-1686 client Task classes.) annotationsN) AwaitableCallable)datetimetimezone) TYPE_CHECKINGGenericTypeVar) GetTaskResultTaskStatusNotification)MessageMessageHandler) get_logger)CallToolResultClientcDa]tRt^tRtRV3RlltRV3RlltRtV;t#)TaskNotificationHandlerzEMessageHandler that routes task status notifications to Task objects.cV^8dQhRR/#)clientr)formats"Z/Users/agent/.openclaw/workspace/venv/lib/python3.14/site-packages/fastmcp/client/tasks.py __annotate__$TaskNotificationHandler.__annotate__sDDvDc Z<\SV`4\P!V4VnR#N)super__init__weakrefref _client_ref)selfr __class__s&&rr TaskNotificationHandler.__init__s 07 F0Crc V^8dQhRRRR/#)rmessager returnNoner)rs"rrr!s((g($(rc <<"\V\PP4'dT\VP\ 4'd4VP 4pV'dVPVP4\SV`%V4GRjxL R#L5i)z7Dispatch messages, including task status notifications.N) isinstancemcptypesServerNotificationrootr r" _handle_task_status_notificationrdispatch)r#r'rr$s&& rr1 TaskNotificationHandler.dispatch!se gsyy;; < <',,(>??))+;;GLLIgw'''sA"B&-BBB)r") __name__ __module__ __qualname____firstlineno____doc__rr1__static_attributes__ __classcell__r$s@rrrsODD((rr TaskResultTc]tRt^/tRtRRRlltRRlt]RRl4t]R R l4t R R lt R Rlt RRlt ] PRRl4tRRRR/RRlltRRltRtRtR#)Taska Abstract base class for MCP background tasks (SEP-1686). Provides a uniform API whether the server accepts background execution or executes synchronously (graceful degradation per SEP-1686). Subclasses: - ToolTask: For tool calls (result type: CallToolResult) - PromptTask: For prompts (future, result type: GetPromptResult) - ResourceTask: For resources (future, result type: ReadResourceResult) Nc$V^8dQhRRRRRR/#)rrrtask_idstrimmediate_resultzTaskResultT | Noner)rs"rrTask.__annotate__<s(7777- 7rc tWnW nW0nVRJVnRVnRVn.VnRVnR#)z Create a Task wrapper. Args: client: The FastMCP client task_id: The task identifier immediate_result: If server executed synchronously, the immediate result N)_client_task_id_immediate_result _is_immediate _status_cache _status_event_status_callbacks_cached_result)r#rr?rAs&&&&rr Task.__init__<sJ  !1-T94837  37rcV^8dQhRR/#rr(r)r)rs"rrrBWsrc VP'dR#VPPpR# \dp\R4ThRp?ii;i)zValidate that client context is still active. Raises: RuntimeError: If accessed outside client context (unless immediate) NzoCannot access task results outside client context. Task futures must be used within 'async with client:' block.)rGrDsession RuntimeError)r#_es& r_check_client_connectedTask._check_client_connectedWsO       $$A O  s. A  AA cV^8dQhRR/#)rr(r@r)rs"rrrBisrc VP#)zGet the task ID.)rEr#s&rr? Task.task_idhs}}rcV^8dQhRR/#)rr(boolr)rs"rrrBns""d"rc VP#)zCheck if server executed the task immediately. Returns: True if server executed synchronously (graceful degradation or no task support) False if server accepted background execution )rGrXs&rreturned_immediatelyTask.returned_immediatelyms!!!rc V^8dQhRRRR/#)rstatusr r(r)r)rs"rrrBwsKK-KDKrc hWnVPeVPP4VPF@pV!V4p\P !V4'd\ P!V4K@KB R# \d&p\PRT 2RR7Rp?KqRp?ii;i)zProcess incoming notifications/tasks/status (internal). Called by Client when a notification is received for this task. Updates cache, triggers events, and invokes user callbacks. Args: status: Task status from notification NzTask callback error: T)exc_info) rHrIsetrJinspect isawaitableasyncio create_task Exceptionloggerwarning)r#r`callbackresultrSs&& r_handle_status_notification Task._handle_status_notificationws$    )    " " $..H K!&)&&v..''///  K!6qc:TJJ Ks:B B1 B,,B1c V^8dQhRRRR/#)rrkz1Callable[[GetTaskResult], None | Awaitable[None]]r(r)r)rs"rrrBs00C0 0rc <VPPV4R#)aRegister callback for status change notifications. The callback will be invoked when a notifications/tasks/status is received for this task (optional server feature per SEP-1686 lines 436-444). Supports both sync and async callbacks (auto-detected). Args: callback: Function to call with GetTaskResult when status changes. Can return None (sync) or Awaitable[None] (async). Example: >>> task = await client.call_tool("slow_operation", {}, task=True) >>> >>> def on_update(status: GetTaskResult): ... print(f"Task {status.taskId} is now {status.status}") >>> >>> task.on_status_change(on_update) >>> result = await task # Callback fires when status changes N)rJappend)r#rks&&ron_status_changeTask.on_status_changes0 %%h/rcV^8dQhRR/#)rr(r r)rs"rrrBs""m"rc "VP4VP'd@\P!\P 4p\ VPRVVRRR7#VPeVPpV#VPPVP4GRjxL VnVP#L5i)zGet current task status. If server executed immediately, returns synthetic completed status. Otherwise queries the server for current status. completedNi)taskIdr` createdAt lastUpdatedAtttl pollInterval) rTrGrnowrutcr rErHrDget_task_status)r#r|cacheds& rr` Task.statuss $$&    ,,x||,C }}"!!      )''FM$(<<#?#? #NN!!!OsB&C(B>)CcV^8dQhRR/#)rr(r;r)rs"rrrBs  k rc "R#5i)zoWait for and return the task result. Must be implemented by subclasses to return the appropriate result type. NrrXs&rrl Task.results sstatetimeoutgr@c$V^8dQhRRRRRR/#)rrz str | Nonerfloatr(r r)rs"rrrBs)=W=W"=W49=W =Wrc "VP4VP'dVP4GRjxL #VPf\P !4Vn\ P !4p0R mpRpVP'd@VPPpVfWd9d VP#MWa8Xd VP#\ P !4V, pWr8d*\RVP RT;'gR RV R24hW', p\P!VPP4\WX4R7GRjxL VPP4EKELLL$ \Pd9TPPTP4GRjxL TnEKUi;i5i) a4Wait for task to reach a specific state or complete. Uses event-based waiting when notifications are available (fast), with fallback to polling (reliable). Optimally wakes up immediately on status changes when server sends notifications/tasks/status. Args: state: Desired state ('submitted', 'working', 'completed', 'failed'). If None, waits for any terminal state (completed/failed) timeout: Maximum time to wait in seconds Returns: GetTaskResult: Final task status Raises: TimeoutError: If desired state not reached within timeout Ng?zTask z did not reach zterminal statez within s)r>failed cancelledrv)rTrGr`rIrfEventtimerH TimeoutErrorrEwait_forwaitminclearrDr~) r#rrstartterminal_states poll_intervalcurrentelapsed remainings &$$ rr Task.waits( $$&    & &    %!(D  > !!!,,33=1#1112%---iikE)G!"DMM?/%:S:SCS9TT\]d\eefg )I W&&&&++-s=7T""((*E'>'' W+/<<+G+G +V%V%V"" Ws_6GFAGAVP4P4#)z!Allow 'await task' to get result.)rl __await__rXs&rrTask.__await__!s{{}&&((r)rKrDrFrGrHrJrIrEr)r3r4r5r6r7rrTpropertyr?r]rmrrr`abcabstractmethodrlrrrr8rrrr=r=/s 76"""K404"<   =W%)=W+22 # > > M Md S,22 # > > M Md S(..t43)(2*d'C'C*% ? Ks*,GAG0G1,GGDrs#"  /'22;;0 H <(n($m$ t)377GK(t)nct$%cL>cii//0>BZcii,,syy/M/MM NOZr