+ Q(i.Rt^RIHt^RIt^RIt^RIt^RIHtHt^RIH t H t H t ^RI t ^RI Ht]P!]4t] 'd^RIHtRtRtR tR tR R ltR RltRRltR#)aYBackground task elicitation support (SEP-1686). This module provides elicitation capabilities for background tasks running in Docket workers. Unlike regular MCP requests, background tasks don't have an active request context, so elicitation requires special handling: 1. Set task status to "input_required" via Redis 2. Send notifications/tasks/status with elicitation metadata 3. Wait for client to send input via tasks/sendInput 4. Resume task execution with the provided input This uses the public MCP SDK APIs where possible, with minimal use of internal APIs for background task coordination. ) annotationsN)datetimetimezone) TYPE_CHECKINGAnycast) ServerSession)FastMCPz2fastmcp:task:{session_id}:{task_id}:elicit:requestz3fastmcp:task:{session_id}:{task_id}:elicit:responsez1fastmcp:task:{session_id}:{task_id}:elicit:statusic 0V^8dQhRRRRRRRRRR R R /#) task_idstrsessionzServerSession | Nonemessageschemadict[str, Any]fastmcpr returnzmcp.types.ElicitResult)formats"f/Users/agent/.openclaw/workspace/venv/lib/python3.14/site-packages/fastmcp/server/tasks/elicitation.py __annotate__r*sT}A}A }A !}A}A  }A  }A  }Ac "VPpVf \R4h\\P!44p^RIHpV!4pVeVPp M\VRR4p V f \R4h\PWR7p \PWR7p \PWR7p RVRVR V/p VP4;_uu_4GRjxL pVPVPV 4\ P"!V 4\$R 7GRjxL VPVPV 4R \$R 7GRjxL RRR4GRjxL \&P(!\*P,4P/4pR R RRVRRRVRVRVR\$R,/RRRVRRRVRRVRVRV////p^RIHpV!V VV4GRjxL \$pTP4;_uu_4GRjxL p\C\DTPGTPT 4.TR 74GRjxL pT'dTwpp\ PH!T4pTP;TPT 4TPT 44GRjxL \<P>PATPKR!R"4TPKR#4R7uuRRR4GRjxL #RRR4GRjxL TP4;_uu_4GRjxL pTP;TPT 4TPT 4TPT 44GRjxL RRR4GRjxL \<P>PARRR7#ELELzELNELA +GRjxL 'giELY;iEL \4dp\6P9RTT4TP4;_uu_4GRjxL pTP;TPT 4TPT 44GRjxL RRR4GRjxL M- +GRjxL 'giM;i \4dMi;i\<P>PARRR7uRp?#Rp?ii;iELELwELELEL +GRjxL 'giEL;i \4d#p\6P9R$TT4Rp?ELRp?ii;iELELEL +GRjxL 'giEL;i \4d#p\6PMR%TT4Rp?ELRp?ii;i5i)&aISend an elicitation request from a background task. This function handles the complexity of eliciting user input when running in a Docket worker context where there's no active MCP request. Args: task_id: The background task ID session: The MCP ServerSession for this task message: The message to display to the user schema: The JSON schema for the expected response fastmcp: The FastMCP server instance Returns: ElicitResult containing the user's response Raises: RuntimeError: If Docket is not available McpError: If the elicitation request fails Nz}Background task elicitation requires Docket. Ensure 'fastmcp[tasks]' is installed and the server has task-enabled components.)get_task_context_fastmcp_state_prefixzCannot determine session_id for elicitation. This typically means elicit_for_task() was called outside a Docket worker context. session_idr request_idrrexwaitingmethodznotifications/tasks/statusparamstaskIdstatusinput_required statusMessage createdAt lastUpdatedAtttli_metaz$io.modelcontextprotocol/related-task elicitation requestIdrequestedSchema)push_notificationzSFailed to queue input_required notification for task %s, cancelling elicitation: %scancel)actioncontent)timeoutr1acceptr2z@BLPOP failed for task %s elicitation, falling back to cancel: %szIFailed to clean up elicitation keys for task %s (will expire via TTL): %s)'_docket RuntimeErrorr uuiduuid4fastmcp.server.dependenciesrrgetattrELICIT_REQUEST_KEYrELICIT_RESPONSE_KEYELICIT_STATUS_KEYredissetkeyjsondumpsELICIT_TTL_SECONDSrnowrutc isoformat"fastmcp.server.tasks.notificationsr/ Exceptionloggerwarningdeletemcptypes ElicitResultrrblpoploadsgetdebug)r rrrrdocketrr task_contextr request_key response_key status_keyelicit_requestr> timestampnotification_dictr/emax_wait_secondsresult_key response_dataresponse cleanup_errors&&&&& relicit_for_taskrb*s4__F ~ _  TZZ\"J=#%L!,, W&=tD  e  %++z+SK&---UL"))Z)QJ j7&N ||~~~ii JJ{ # JJ~ &!   ii JJz " !   ~( X\\*446I. g & W  Y %,    2'*w%v  5  4EE ,=vFFF.*! <<>>>U  ZZ -.,F&,#m::m4llJJ{+JJz* yy--#<<(;$LL3./">>>>H  <<>>>U,, ;' <( :&  "> 99 ! !4 ! @@}  ~~~d G E  a    ||~~~llJJ{+JJz*&~~~~~    yy%%Xt%DD#E2"#">>>6   N     " ">>>   W     sCUNU ?N"N .N"NN" UNA+U ON?OU$SR-S5R<9R0: R<AR<R3AR< S%R6&S*U+ S6R97S<T/T T/AT T !T% T/0T1T/5"UN"N"U"N< (N+) N< 4N< 6 U?O R* R%%Q.P Q.4Q:P= ;Q Q. Q Q.R%Q+ Q Q+ $Q+ &Q.*R%+Q.. Q<9R%;Q<<#R%R* U%R**U-S0R<3R<6S9S<S S S S SUS T$T;UTU T/ TT/T, T T, $T, &T/*U,T// U:UUUUc 0V^8dQhRRRRRRRRRR R R /#) r rrrr r r,rrr rNoner)rs"rrrsD55 555 5  5  5rc "VPVR,VR,R7GRjxL p\VVVPVPVR7GRjxL \P RVVP4R#LSL) \ d_p\PRY&4\TTRRTR7GRjxL pT'g\PR T4Rp?R#Rp?R#Rp?ii;i5i) a Relay elicitation from a background task worker to the client. Called by the notification subscriber when it detects an input_required notification with elicitation metadata. Sends a standard elicitation/create request to the client session, then uses handle_task_input() to push the response to Redis so the blocked worker can resume. Args: session: MCP ServerSession session_id: Session identifier task_id: Background task ID elicitation: Elicitation metadata (message, requestedSchema) fastmcp: FastMCP server instance rr.)rr.N)r rr1r2rz4Relayed elicitation response for task %s (action=%s)z+Failed to relay elicitation for task %s: %sr0zGFailed to push cancel response for task %s (worker may block until TTL))elicithandle_task_inputr1r2rIrRrHrJ)rrr r,rr]r[successs&&&&& rrelay_elicitationris* ~~ *'(9:&   !==NN      B  MM    DgQ)!     NN/  sbC,$BA<+BA>%B:C,<B>B C) )C$4B75 C$C$ C,$C))C,c 0V^8dQhRRRRRRRRRRR R /#) r r r rr1r2zdict[str, Any] | Nonerr rboolr)rs"rrr"sD88 88 8# 8  8  8rc,"VPpVfR#\PWR7p\PWR7pRVRV/pVP 4;_uu_4GRjxL p V P VP V44GRjxL p V eV PR4R8wdRRR4GRjxL R#V PVP V4\P!V44GRjxL V PVP V4\4GRjxL V PVP V4R\R 7GRjxL RRR4GRjxL R #ELLLLyLNL!L +GRjxL 'giR #;i5i) aHandle input sent to a background task via tasks/sendInput. This is called when a client sends input in response to an elicitation request from a background task. Args: task_id: The background task ID session_id: The MCP session ID action: The elicitation action ("accept", "decline", "cancel") content: The response content (for "accept" action) fastmcp: The FastMCP server instance Returns: True if the input was successfully stored, False otherwise NFrr1r2zutf-8r! respondedrT)r5r<rr=r>rQr@decodelpushrArBexpirerCr?) r rr1r2rrSrVrWr`r>r%s &&&&& rrgrg"sU,__F ~&---UL"))Z)QJ &7H ||~~~yyJ!788 >V]]73y@ ~~kk JJ| $ JJx    ll6::l35GHHHii JJz " !   !~, -8 I !~~~, sA!F#E($F'$E7 E+ E7+ F6E-7F=8E75E/6,E7"E1#.E7E3E7 F!E5"F+E7-F/E71E73E75F7F =F> F F F)__doc__ __future__rrAloggingr7rrtypingrrr mcp.typesrLr getLogger__name__rIfastmcp.server.serverr r;r<r=rCrbrirgrrrrysm #  '++   8 $-JKG}A@5p8r