+ Q(iRt^RIHt^RIHt^RIHtHt^RIHt^RI H t ^RI H t H t ^RIHt^RIHt^R IHt^R IHt]'d^R IHt^R I Ht^R IHt]!]4tRRRlltRRRlltRRRlltR#)a Task subscription helpers for sending MCP notifications (SEP-1686). Subscribes to Docket execution state changes and sends notifications/tasks/status to clients when their tasks change state. This module requires fastmcp[tasks] (pydocket). It is only imported when docket is available. ) annotations)suppress)datetimetimezone) TYPE_CHECKING)ExecutionState)TaskStatusNotificationTaskStatusNotificationParams)DEFAULT_TTL_MS)parse_task_key)DOCKET_TO_MCP_STATE) get_logger)Docket) Execution) ServerSessionc 0V^8dQhRRRRRRRRRR R R /#) task_idstrtask_keysessionrdocketrpoll_interval_msintreturnNone)formats"h/Users/agent/.openclaw/workspace/venv/lib/python3.14/site-packages/fastmcp/server/tasks/subscriptions.py __annotate__rsL2V2V 2V2V2V  2V  2V  2Vc "VPV4GRjxL pVf\PRV 24R#VP4RjxL pVR,R8Xd,\ VVVV\ VR,4VR7GRjxL KCVR,R8XgKS\ VVVVVVR7GRjxL KnLLkL5L DpR# \d)p\PRT R T 2R R 7Rp?R#Rp?ii;i5i) aGSubscribe to Docket execution events and send MCP notifications. Per SEP-1686 lines 436-444, servers MAY send notifications/tasks/status when task state changes. This is an optional optimization that reduces client polling frequency. Args: task_id: Client-visible task ID (server-generated UUID) task_key: Internal Docket execution key (includes session, type, component) session: MCP ServerSession for sending notifications docket: Docket instance for subscribing to execution events poll_interval_ms: Poll interval in milliseconds to include in notifications NzNo execution found for task typestate)rrrrr#rprogress)rrrr executionrzSubscription task failed for z: T)exc_info) get_executionloggerwarning subscribe_send_status_notificationr_send_progress_notification Exception)rrrrrr%eventes&&&&& rsubscribe_to_task_updatesr0s(V ..x88   NN9'C D %..0  %V}'/##%!(w8%5 v*,1##%!'%5 '9  1, V6wir!EPTUUVsC:CB9 CC:C CB;C4CB=CC2B?3C;C=C?CCC: C7C2,C:2C77C:c4V^8dQhRRRRRRRRRR R R R R /#)rrrrrrrrr#rrrrrr)rs"rrrTsWC6C6 C6 C6C6  C6  C6  C6 C6r c "\pVPVR4p\V4pVR,p VPRV RV R24p VP 4;_uu_4GRjxL p V PV 4GRjxL p RRR4GRjxL X 'dV P R4M1\ P!\P4P4p RpV\P8XdRpM/V\P8XdR pMV\P8XdR pR VR VR V R\ P!\P4P4R\RV/pV'dWR&\!\"P$!V4R7p\'\(4;_uu_4VP+V4GRjxL RRR4R#ELkELUELH +GRjxL 'giEL`;iL4 +'giR#;i5i)aSend notifications/tasks/status to client. Per SEP-1686 line 454: notification SHOULD NOT include related-task metadata (taskId is already in params). Args: session: MCP ServerSession task_id: Client-visible task ID task_key: Internal task key (for metadata lookup) docket: Docket instance state: Docket execution state (enum) poll_interval_ms: Poll interval in milliseconds failed session_id fastmcp:task:: :created_atNutf-8zTask completed successfullyz Task failedzTask cancelledtaskIdstatus createdAt lastUpdatedAtttl pollInterval statusMessageparams)r getr keyredisdecodernowrutc isoformatr COMPLETEDFAILED CANCELLEDr rr model_validaterr-send_notification)rrrrr#r state_map mcp_status key_partsr4created_at_keyrDcreated_at_bytes created_atstatus_message params_dict notifications&&&&&& rr+r+Ts,$Iuh/Jx(I<(JZZ- |1WI[ QRN||~~~!&>!::~  ( \\(,, ' 1 1 3N (((6 .'' '& .** *) '*Zhll3==? ~( K'5O$*+::;GL )  '' 555  I:~~~J 6   sA!H #G$H 'G<G=G H  G H CH /;H *G6?G4G6 H GH G1 G  G1 )G1 + H 4G66 H  H c4V^8dQhRRRRRRRRRR R R R R /#)rrrrrrrrr%rrrrrr)rs"rrrsN;6;6 ;6 ;6;6  ;6  ;6  ;6 ;6r cD"VP4GRjxL VP'dVPP'gR#\pVP VP R4p\ V4pVR,p VPRV RV R24p VP4;_uu_4GRjxL p V P V 4GRjxL p RRR4GRjxL X 'dV PR4M1\P!\P4P4p RVR VR V R \P!\P4P4R \R VRVPP/p\!\"P$!V4R7p\'\(4;_uu_4VP+V4GRjxL RRR4R#ELEL/ELEL +GRjxL 'giEL$;iL7 +'giR#;i5i)a'Send notifications/tasks/status when progress updates. Args: session: MCP ServerSession task_id: Client-visible task ID task_key: Internal task key docket: Docket instance execution: Execution object with current progress poll_interval_ms: Poll interval in milliseconds Nr3r4r5r6r7r8r9r:r;r<r=r>r?r@)syncr$messager rBr#r rCrDrErrFrrGrHr rr rLrr-rM)rrrrr%rrNrOrPr4rQrDrRrSrUrVs&&&&&& rr,r,s& ..     Y%7%7%?%?%?$Iy9Jx(I<(JZZ- |1WI[ QRN||~~~!&>!::~  ( \\(,, ' 1 1 3 '*Zhll3==? ~(++33K*+::;GL )  '' 555  O:~~~2 6   sH G!H H  A,H 5G$6H 9G-G'G- H G* H +CH =H H H  H $H 'G-*H -H 3G64 H ?H  H  H  H  H N)i) __doc__ __future__r contextlibrrrtypingrdocket.executionr mcp.typesrr fastmcp.server.tasks.configr fastmcp.server.tasks.keysr fastmcp.server.tasks.requestsr fastmcp.utilities.loggingr rrrmcp.server.sessionr__name__r(r0r+r,rr rrgsX#' +J64=0*0 H 2VjC6L;6;6r