+ wi0@^RIt^RIt^RIt^RIt^RIHtHt^RIHtHt^RI H t H t H t H t HtHtHtHtHtHt^RIt^RIHt^RIHt^RIHt^RIHt^R IHtHtH t H!t!^R I"H#t#H$t$]PJ!]&4t']!R R 44t(]PR!4t*R Rlt+Rt,RRlt-RRlt.!RR]/4t0!RR4t1^RI2H3t3]3Ph]1n5]1Ph]3n4]]8]9]:]#] 3,t;]];,t<] ];,t=]]=]<3,t>!RR]4t?R# ]6d]'PoR4LRi;i)N) dataclassfield)datetimetimezone) Any AsyncIterable AwaitableCallable CoroutineIteratorMappingOptionalSetUnion)BackgroundTask)iterate_in_threadpool)MutableHeaders)Response)ReceiveScopeSendMessage)ServerSentEvent ensure_bytescFa]tRt^!toRt]!]R7tRtV3Rlt Rt Vt R#)_ShutdownStatezPer-thread state for shutdown coordination. Issue #152 fix: Uses threading.local() instead of ContextVar to ensure one watcher per thread rather than one per async context. )default_factoryFcV<V^8dQh/S[S[P,;R&S[;R&#)eventswatcher_started)ranyioEventbool)format __classdict__s"E/home/ubuntu/.local/lib/python3.14/site-packages/sse_starlette/sse.py __annotate___ShutdownState.__annotate__!s(  9!N) __name__ __module__ __qualname____firstlineno____doc__rsetr r!__annotate_func____static_attributes____classdictcell__r&s@r'rr!s" %S9F!Or*rc$V^8dQhR\/#rreturn)r)r%s"r'r(r(1s^r*cZ\\RR4pVf\4pV\nV#)z4Get or create shutdown state for the current thread.shutdown_stateN)getattr _thread_staterr:)states r'_get_shutdown_stater>1s+ M#3T :E } ', $ Lr*c\P!\P4p\VR4'd!VPp\VR4'dV#R# \ dR#i;i)aM Try to get uvicorn Server instance via signal handler introspection. When uvicorn registers signal handlers, they're bound methods on the Server instance. We can retrieve the Server from the handler's __self__ attribute. Returns None if: - Not running under uvicorn - Signal handler isn't a bound method - Any introspection fails __self__ should_exitN)signal getsignalSIGTERMhasattrr@ Exception)handlerservers r'_get_uvicorn_serverrI:sa ""6>>2 7J ' '%%Fv}--      sAA A)(A)cV^8dQhRR/#rr8Nr+)r%s"r'r(r(Qs!&!&!&r*c"\4p\4p\P'dMX\P'd#VeVP'd R\nM \ P !R4GRjxL Kp\VP4FpVP4K RVn R#L; RTn i;i5i)aO Poll for shutdown and broadcast to all events in this context. One watcher runs per thread (event loop). Checks two shutdown sources: 1. AppStatus.should_exit - set when our monkey-patch works 2. uvicorn Server.should_exit - via signal handler introspection (Issue #132 fix) When either becomes True, signals all registered events. TNg?F) r>rI AppStatusrAenable_automatic_graceful_drainr"sleeplistr r1r!)r=uvicorn_serverevents r'_shutdown_watcherrSQs !E(*N&$$$999"."...(, %++c" " "%,,'E IIK(!& #!&s?C B?B?B?%B?B=2B?4 C =B?? CC cV^8dQhRR/#rKr+)r%s"r'r(r(us * *d *r*c\4pVP'g9RVn\P!4pVP \ 44R#R# \ d RTnR#i;i)zDEnsure the shutdown watcher is running for this thread (event loop).TFN)r>r!asyncioget_running_loop create_taskrS RuntimeError)r=loops r'$_ensure_watcher_started_on_this_loopr[usa  !E  $ *++-D   .0 1 !  *$)E ! *s.AA-,A-c]tRt^tRtR#)SendTimeoutErrorr+N)r,r-r.r/r3r+r*r'r]r]sr*r]cla]tRt^toRtRtRtRt]R4t ]R4t ]R4t V3Rlt R t VtR#) rMz\Helper to capture a shutdown signal from Uvicorn so we can gracefully terminate SSE streams.FTNc R\nR#)a Prevent automatic SSE stream termination on server shutdown. WARNING: When disabled, you MUST set AppStatus.should_exit = True at some point during shutdown, or streams will never close and the server will hang indefinitely (or until uvicorn's graceful shutdown timeout expires). FNrMrNr+r*r' disable_automatic_graceful_drain*AppStatus.disable_automatic_graceful_drains 5: 1r*c R\nR#)z Re-enable automatic SSE stream termination on server shutdown. This restores the default behavior where SIGTERM triggers immediate stream draining. Call this to undo a previous call to disable_automatic_graceful_drain(). TNr`r+r*r'$enable_automatic_graceful_drain_mode.AppStatus.enable_automatic_graceful_drain_modes 59 1r*c\P'd R\n\Pe\P!V/VBR#R#)TN)rMrNrAoriginal_handler)argskwargss*,r' handle_exitAppStatus.handle_exits:  4 4 4$(I !  % % 1  & & 7 7 2r*c6<V^8dQh/S[S[,;R&#)rrg)rr )r%r&s"r'r(AppStatus.__annotate__s x(/ r*r+)r,r-r.r/r0rArNrg staticmethodrardrjr2r3r4r5s@r'rMrMsZfK&*#+/ : :9988?r*rM)ServerzHUvicorn not installed. Graceful shutdown on server termination disabled.ca]tRt^toRt^tRtRV3RlRllt]V3RlRl4t ] PV3RlR l4t RV3R lR llt V3R lR lt V3RlRlt ]V3RlRl4tV3RlRltV3RlRltV3RlRltRtVtR#)EventSourceResponseaStreaming response implementing the SSE (Server-Sent Events) specification. Args: content: Async iterable or sync iterator yielding SSE event data. status_code: HTTP status code. Default: 200. headers: Additional HTTP headers. media_type: Response media type. Default: "text/event-stream". background: Background task to run after response completes. ping: Ping interval in seconds (0 to disable). Default: 15. sep: Line separator for SSE messages ("\r\n", "\r", or "\n"). ping_message_factory: Callable returning custom ping ServerSentEvent. data_sender_callable: Async callable for push-based data sending. send_timeout: Timeout in seconds for individual send operations. client_close_handler_callable: Async callback on client disconnect. shutdown_event: Optional ``anyio.Event`` set by the library when server shutdown is detected. Generators can watch this event to send farewell messages and exit cooperatively instead of receiving CancelledError. shutdown_grace_period: Seconds to wait after setting ``shutdown_event`` before force-cancelling the generator. Must be >= 0. Should be less than your ASGI server's graceful shutdown timeout. Default: 0 (immediate cancel, identical to pre-v3.3.0 behavior).  Nc<V^8dQhRS[RS[RS[S[S[S[3,,RS[RS[S[,RS[S[,RS[S[,RS[S[.S[3,,R S[S[.S[R,3,,R S[S[ ,R S[S[S[ .S[ R ,3,,R S[S[ P,RS[ RR /#)rcontent status_codeheaders media_type backgroundpingsepping_message_factorydata_sender_callableN send_timeoutclient_close_handler_callableshutdown_eventshutdown_grace_periodr8)NNN) ContentStreamintrr strrr rr floatrr r"r#)r%r&s"r'r( EventSourceResponse.__annotate__sG'G'G'G''#s(+, G'  G' ^, G'smG'c]G''xO0C'DEG'' R#344 5 G'uoG'(0 gY $/ 0( G'"!-#G'$ %%G'& 'G'r*czVR 9d\RV 24hT;'g VPVn\V\4'dWnM\ V4VnW nVf VPMTVnWPn Wn Wn \4pVeVPV4VPRR4RVR&RVR&VPV4Vf VP MTVnWnWnV ^8d \R4hWnWnR Vn\.P0!4VnR#) Nz'sep must be one of: \r\n, \r, \n, got: z Cache-Controlzno-storez keep-alive ConnectionnozX-Accel-Bufferingz"shutdown_grace_period must be >= 0T)Nrr  ) ValueErrorDEFAULT_SEPARATORrz isinstancer body_iteratorrrurwrxr|r}rupdate setdefault init_headersDEFAULT_PING_INTERVAL ping_intervalr{r~_shutdown_event_shutdown_grace_periodactiver"Lock _send_lock)selfrtrurvrwrxryrzr{r|r}r~rr_headerss&&&&&&&&&&&&&& r'__init__EventSourceResponse.__init__s'* 0 0J3%PQ Q00$00 g} - -!( !6w!?D &-7-?$//Z$$8!("#   OOG $ OZ8!-(,$% (#;?<FE2EE2 F*E-+F2F 8E;9 F F  Fc$<V^8dQhRS[RR/#)rreceiver8N)r)r%r&s"r'r(rKs  G  r*c "VP'diV!4GRjxL pVR,R8XgK1RVn\PR4VP'dVPV4GRjxL R#R#L_L 5i)z/Watch for a disconnect message from the client.Nrzhttp.disconnectFz+Got event: http.disconnect. Stop streaming.)rrrr~)rrmessages&& r'_listen_for_disconnect*EventSourceResponse._listen_for_disconnectKsikkk#IoGv"33#  JK555<r"r#r adddiscardwait)r=rRs r'_listen_for_exit_signal+EventSourceResponse._listen_for_exit_signalVs  ,.#%   ($$$ LL  '**,   LL  '  LL  's<AC+ C 7C+C 'C (C ,C+ C C((C+c<V^8dQhRR/#rKr+)r%r&s"r'r(rjs++$+r*c "VP4GRjxL VP'dVPP4VP^8dg\P !VP4;_uu_4VP 'd!\P!R4GRjxL K2RRR4R#R#LL +'giR#;i5i)aVWait for shutdown signal, then optionally give generator a grace period. Issue #167: When a shutdown_event is provided, the library sets it before returning, giving the generator a chance to send farewell events and exit cooperatively. The shutdown_grace_period controls how long to wait before force-cancelling via task group cancellation. Ng?)rrr1rr"rrrOrs&r'"_listen_for_exit_signal_with_grace6EventSourceResponse._listen_for_exit_signal_with_gracejs**,,,      $ $ &  & & *$$T%@%@AAkkk++c***"BA + -+BAAsECCCACCC,C-C4 CC C  Cc$<V^8dQhRS[RR/#rr)r%r&s"r'r(r~sr*c "VP'Ed \P!VP4GRjxL VP'dVP 4M;\ R\ P!\P4 2VPR7p\W P4p\PRV4VP;_uu_4GRjxL VP'dV!RRRVRR /4GRjxL RRR4GRjxL EKR#LLCLL +GRjxL 'giEKA;i5i) zPeriodically send ping messages to keep the connection alive on proxies. - frequenccy ca every 15 seconds. - Alternatively one can send periodically a comment line (one starting with a ':' character) Nzping - )commentrzzping: %srrrrT)rr"rOrr{rrnowrutcrzrrrr)rrsse_ping ping_bytess&& r'_pingEventSourceResponse._ping~s kkk++d112 2 2,,,))+$%hll8<<&@%AB &h9J LLZ 0;;;"$8"J'' 2''s{E#ED!EBED# E#$D)D%D) ED' E#E%D)'E)E /D20 E ;E = Ec0<V^8dQhRS[RS[RS[RR/#)rscoperrr8N)rrr)r%r&s"r'r(rs)$$E$G$4$D$r*c Daaaa"\P!4;_uu_4GRjxL oRV3RllpSPVVV3Rl4SPVVV3Rl4SPVSP4SP'dSPSP4SPVVV3Rl4RRR4GRjxL SP eSP 4GRjxL R#R#LL0 +GRjxL 'giLG;iL(5i)zEntrypoint for Starlette's ASGI contract. We spin up tasks: - _stream_response to push events - _ping to keep the connection alive - _listen_for_exit_signal to respond to server shutdown - _listen_for_disconnect to respond to client disconnect NcLV^8dQhR\.\R,3,/#)rcoroN)r r )r%s"r'r(2EventSourceResponse.__call__..__annotate__s! 1 1Xb)D/6I-J 1r*cf<"V!4GRjxL SPP4R#L 5ir)rcancel)r task_groups&r'cancel_on_finish6EventSourceResponse.__call__..cancel_on_finishs&f ''..0s 1/!1c&<SPS4#r)rrrsr'.EventSourceResponse.__call__..sDD BD D D%D 5D6 D D D D  D D  D )rrrrrrxrr~r|rwrr{r}rzru) Nztext/event-streamNNNNNNNNr)F)r,r-r.r/r0rrrpropertyrsetterrrrrnrrrrr3r4r5s@r'rqrqs.G'G'R##$$SSXX8  ((&++(6$$r*rq)@rVloggingrB threading dataclassesrrrrtypingrrr r r r r rrrr"starlette.backgroundrstarlette.concurrencyrstarlette.datastructuresrstarlette.responsesrstarlette.typesrrrrsse_starlette.eventrr getLoggerr,rrlocalr<r>rIrSr[ TimeoutErrorr]rM uvicorn.mainrorjrg ImportErrorrrbytesdictContentSyncContentStreamAsyncContentStreamrrqr+r*r'r s5 ('    /73(99=   8 $ "" "! .!&H * | #8#8L#!'!3!3I"..F UD/36 7W%"7+(*;;< y$(y$ LLRs(D&&EE