&e ddlZddlmZddlmZddlmZmZddlm Z ddl m Z ddl m Z Gdd eZed Gd d Zed GddZGddZdS)N) dataclass)Enum)Optionalcast)util) WidgetStates)coalesce_widget_statesceZdZdZdZdZdS)ScriptRequestTypeCONTINUESTOPRERUNN)__name__ __module__ __qualname__r r rNlib/python3.11/site-packages/streamlit/runtime/scriptrunner/script_requests.pyr r s!H D EEErr T)frozencdeZdZUdZdZeed<dZee ed<dZ eed<dZ eed<defd Z dS) RerunDataz+Data attached to RERUN requests. Immutable. query_stringN widget_statespage_script_hash page_namereturnc*tj|SNrrepr_selfs r__repr__zRerunData.__repr__0z$r) rrr__doc__rstr__annotations__rrrrrr$rrrrr's}55L#,0M8L)000cIs #      rrc`eZdZUdZeed<dZeeed<e defdZ de fdZ dS) ScriptRequestz,A STOP or RERUN request and associated data.typeN _rerun_datarcz|jtjurtdt t |jS)Nz)RerunData is only set for RERUN requests.)r+r r RuntimeErrorrrr,r"s r rerun_datazScriptRequest.rerun_data;s5 9-3 3 3JKK KIt/000rc*tj|Srr r"s rr$zScriptRequest.__repr__Ar%r) rrrr&r r(r,rrpropertyr/r'r$rrrr*r*4s}66 '+K)$+++ 1I111X1  #      rr*cTeZdZdZdZd dZdedefdZde e fdZ de fd Z dS) ScriptRequestszAn interface for communicating with a ScriptRunner. Thread-safe. AppSession makes requests of a ScriptRunner through this class, and ScriptRunner handles those requests. c~tj|_tj|_t |_dSr) threadingLock_lockr r _staterr,r"s r__init__zScriptRequests.__init__Ls-^%% '0 $;;rrNch|j5tj|_ddddS#1swxYwYdS)zRequest that the ScriptRunner stop running. A stopped ScriptRunner can't be used anymore. STOP requests succeed unconditionally. N)r7r r r8r"s r request_stopzScriptRequests.request_stopQszZ 1 1+0DK 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1s '++new_datacT|j5|jtjkr ddddS|jtjkr&tj|_||_ ddddS|jtjkr|jj||_ ddddS|jTt|jj|j}t|j ||j |j |_ ddddS ddddStd|j#1swxYwYdS)a5Request that the ScriptRunner rerun its script. If the ScriptRunner has been stopped, this request can't be honored: return False. Otherwise, record the request and return True. The ScriptRunner will handle the rerun request as soon as it reaches an interrupt point. NFT)rrrrz Unrecognized ScriptRunnerState: )r7r8r r r rr,rr rrrrr.)r#r<coalesced_statess r request_rerunzScriptRequests.request_rerunXs3Z, Q, Q{/444, Q, Q, Q, Q, Q, Q, Q, Q {/88805 #+ , Q, Q, Q, Q, Q, Q, Q, Q{/555#19 (0D$-, Q, Q, Q, Q, Q, Q, Q, Q0)5(>(68N(($(1%-%:&6)1)B"*"4 (((D$  I, Q, Q, Q, Q, Q, Q, Q, QRS, Q, Q, Q, Q, Q, Q, Q, QXO$+OOPP PY, Q, Q, Q, Q, Q, Q, Q, Q, Q, Qs/D.D')DAD8DDD!$D!ct|jtjkrdS|j5|jtjkrNOO 9 9 9 9 9 9 9 9 ;"3"88888 !2!788  9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9sAB-1/B--B14B1c:|j5|jtjkrNOO 9 9 9 9 9 9 9 9,0DK !2!788 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9sAB)BBB)rN) rrrr&r9r;rboolr?rr*rArCrrrr3r3Es ''' 11116Qi6QD6Q6Q6Q6Qp9x '>999929}999999rr3)r5 dataclassesrenumrtypingrr streamlitr streamlit.proto.WidgetStates_pb2rstreamlit.runtime.stater r rr*r3rrrrKso!!!!!!!!!!!!!!999999::::::         $           $          v9v9v9v9v9v9v9v9v9v9r