i5LSrSSKrSSKrSSKJr SSKJrJrJrJ r J r J r J r J r JrJrJrJr "SS\5r"SS \5r"S S \5r"S S 5r"SS5r\R."5rSqSrSrSrSrSSjrSrSSjr Sr!Sr"Sr#SSjr$Sr%Sr&Sr'g)aL Stash - Global Shared State for Dirty Workers Provides simple key-value tables stored in the arbiter process. All workers can read and write to the same tables. Usage:: from gunicorn.dirty import stash # Basic operations - table is auto-created on first access stash.put("sessions", "user:1", {"name": "Alice", "role": "admin"}) user = stash.get("sessions", "user:1") stash.delete("sessions", "user:1") # Dict-like interface sessions = stash.table("sessions") sessions["user:1"] = {"name": "Alice"} user = sessions["user:1"] del sessions["user:1"] # Query operations keys = stash.keys("sessions") keys = stash.keys("sessions", pattern="user:*") # Table management stash.ensure("cache") # Explicit creation (idempotent) stash.clear("sessions") # Delete all entries stash.delete_table("sessions") # Delete the table itself tables = stash.tables() # List all tables Declarative usage in DirtyApp:: class MyApp(DirtyApp): stashes = ["sessions", "cache"] # Auto-created on arbiter start def __call__(self, action, *args, **kwargs): # Tables are ready to use stash.put("sessions", "key", "value") Note: Tables are stored in the arbiter process and are ephemeral. If the arbiter restarts, all data is lost. N) DirtyError) DirtyProtocol STASH_OP_PUT STASH_OP_GETSTASH_OP_DELETE STASH_OP_KEYSSTASH_OP_CLEAR STASH_OP_INFOSTASH_OP_ENSURESTASH_OP_DELETE_TABLESTASH_OP_TABLESSTASH_OP_EXISTSmake_stash_messagec\rSrSrSrSrg) StashErrorEz$Base exception for stash operations.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__rF/var/www/ias/venv/lib/python3.13/site-packages/gunicorn/dirty/stash.pyrrEs.rrc,^\rSrSrSrU4SjrSrU=r$)StashTableNotFoundErrorIz#Raised when a table does not exist.c6>Xl[TU] SU35 g)NzStash table not found: ) table_namesuper__init__)selfr! __class__s rr# StashTableNotFoundError.__init__Ls$ 2:,?@r)r!rrrrrr#r __classcell__r%s@rrrIs-AArrc,^\rSrSrSrU4SjrSrU=r$)StashKeyNotFoundErrorQz,Raised when a key does not exist in a table.cH>XlX l[TU] SUSU35 g)NzKey not found in z: )r!keyr"r#)r$r!r.r%s rr#StashKeyNotFoundError.__init__Ts($ ,ZL3%@Ar)r.r!r'r)s@rr+r+Qs6BBrr+c\rSrSrSrSSjrSrSrSrSSjr S r SS jr S r SS jr S rSrSrSSjrSrSrSrSrSrSrSrg) StashClientZz` Client for stash operations. Communicates with the arbiter which stores all tables in memory. c^XlX lSUl[R"5Ulg)z Initialize the stash client. Args: socket_path: Path to the dirty arbiter's Unix socket timeout: Default timeout for operations in seconds N) socket_pathtimeout_sock threadingLock_lock)r$r4r5s rr#StashClient.__init__as$'  ^^% rc>[[R"55$)zGenerate a unique request ID.)struuiduuid4r$s r_get_request_idStashClient._get_request_idns4::<  rc|SSKnURbgURURUR5UlURR UR 5 URR UR5 g!UR[4anSUl[SU35UeSnAff=f)z Establish connection to arbiter.rNzFailed to connect to arbiter: ) socketr6AF_UNIX SOCK_STREAM settimeoutr5connectr4errorOSErrorr)r$rCes r_connectStashClient._connectrs :: !  Jv~~v7I7IJDJ JJ ! !$,, / JJ  t// 0 g& JDJ=aSAB I JsA5B B; B66B;cURb#URR5 SUlgg![a Nf=f)zClose the connection.N)r6close Exceptionr?s r_closeStashClient._closesC :: !    "DJ "  s 2 ??Nc JUR URcUR5 UR5n[ XaUX4US9n[ R "URU5 [ R"UR5nURS5n U [ R:XaURS5sSSS5 $U [ R:XacURS05n U RSS5n U RSS 5n U S :Xa [U5eU S :Xa [X#5e[U 5e[S U 35e![a:n UR5 [!U [5(ae[S U 35U eSn A ff=f!,(df  g=f)z Execute a stash operation. Args: op: Operation code (STASH_OP_*) table: Table name key: Optional key value: Optional value pattern: Optional pattern for keys operation Returns: Result from the operation N)r.valuepatterntyperesultrH error_typermessagez Unknown errorrr+zUnexpected response type: zStash operation failed: )r9r6rKr@rr write_message read_messagegetMSG_TYPE_RESPONSEMSG_TYPE_ERRORrr+rrOrP isinstance)r$optabler.rSrT request_idrXresponsemsg_type error_inforW error_msgrJs r_executeStashClient._executeskZZzz! --/J(gG  H++DJJ@(55djjA#<</}>>>#<<1!Z"!=!==!)gr!:J!+ l!KJ *y/ JI!%>>5e<<!%<<3E??$Y//$'A(%LMM H a,, #;A3!?@aG  H=Zs1:FA6E BE  F5F  FF F"c.UR[XUS9 g)z Store a value in a table. The table is automatically created if it doesn't exist. Args: table: Table name key: Key to store under value: Value to store (must be serializable) )r.rSN)rfr)r$r`r.rSs rputStashClient.puts lE% @rcPUR[XS9$![a Us$f=f)z Retrieve a value from a table. Args: table: Table name key: Key to retrieve default: Default value if key not found Returns: The stored value, or default if not found r.)rfrr+)r$r`r.defaults rr[StashClient.gets. ==u=> >$ N s  %%c*UR[XS9$)z Delete a key from a table. Args: table: Table name key: Key to delete Returns: True if key was deleted, False if it didn't exist rl)rfrr$r`r.s rdeleteStashClient.delete}}_e}==rc*UR[XS9$)z Get all keys in a table, optionally filtered by pattern. Args: table: Table name pattern: Optional glob pattern (e.g., "user:*") Returns: List of keys rT)rfr )r$r`rTs rkeysStashClient.keyss}}]E}CCrc0UR[U5 g)z= Delete all entries in a table. Args: table: Table name N)rfr r$r`s rclearStashClient.clears ne,rc.UR[U5$)zm Get information about a table. Args: table: Table name Returns: Dict with table info (size, etc.) )rfr rys rinfoStashClient.infos}}]E22rc0UR[U5 g)z Ensure a table exists (create if not exists). This is idempotent - calling it multiple times is safe. Args: table: Table name N)rfr rys rensureStashClient.ensure s ou-rc*UR[XS9$)z Check if a table or key exists. Args: table: Table name key: Optional key to check within the table Returns: True if exists, False otherwise rl)rfrrps rexistsStashClient.existsrsrc0UR[U5 g)z6 Delete an entire table. Args: table: Table name N)rfr rys r delete_tableStashClient.delete_table$s +U3rc.UR[S5$)z4 List all tables. Returns: List of table names )rfrr?s rtablesStashClient.tables-s}}_b11rc[X5$)ze Get a dict-like interface to a table. Args: name: Table name Returns: StashTable instance ) StashTable)r$names rr`StashClient.table6s$%%rcpUR UR5 SSS5 g!,(df  g=f)zClose the client connection.N)r9rPr?s rrNStashClient.closeBs ZZ KKMZZs' 5cU$Nrr?s r __enter__StashClient.__enter__Gs rc$UR5 gr)rN)r$exc_typeexc_valexc_tbs r__exit__StashClient.__exit__Js  r)r9r6r4r5)g>@)NNNr)rrrrrr#r@rKrPrfrir[rqrvrzr}rrrrr`rNrrrrrrr1r1Zsk &! J0Hl A" > D- 3 . >42 & rr1cx\rSrSrSrSr\S5rSrSr Sr Sr S r S r SS jrSS jrSrSrSrSrg )riNa  Dict-like interface to a stash table. Example:: sessions = stash.table("sessions") sessions["user:1"] = {"name": "Alice"} user = sessions["user:1"] del sessions["user:1"] # Iteration for key in sessions: print(key, sessions[key]) cXlX lgr_client_name)r$clientrs rr#StashTable.__init__^s   rcUR$)z Table name.)rr?s rrStashTable.namebszzrcURRURU5nUc6URRURU5(d [ U5eU$r)rr[rrKeyError)r$r.rVs r __getitem__StashTable.__getitem__gsK!!$**c2 ><<&&tzz377sm# rcPURRURX5 gr)rrir)r$r.rSs r __setitem__StashTable.__setitem__os S0rcpURRURU5(d [U5egr)rrqrrr$r.s r __delitem__StashTable.__delitem__rs,||""4::s333- 4rcNURRURU5$r)rrrrs r __contains__StashTable.__contains__vs||""4::s33rc^[URRUR55$r)iterrrvrr?s r__iter__StashTable.__iter__ys DLL%%djj122rcpURRUR5nURSS5$)Nsizer)rr}rr[)r$r}s r__len__StashTable.__len__|s+||  ,xx""rNcNURRURX5$)zGet value with default.)rr[r)r$r.rms rr[StashTable.gets|| C99rcJURRURUS9$)z-Get all keys, optionally filtered by pattern.ru)rrvr)r$rTs rrvStashTable.keyss ||  W ==rcNURRUR5 g)zDelete all entries.N)rrzrr?s rrzStashTable.clears 4::&rc## URRUR5H,nXRRURU54v M. g7f)z Iterate over (key, value) pairs.Nrrvrr[rs ritemsStashTable.itemss@<<$$TZZ0C||'' C88 81sAAc## URRUR5H+nURRURU5v M- g7f)zIterate over values.Nrrs rvaluesStashTable.valuess=<<$$TZZ0C,,""4::s3 31sAArr)rrrrrr#propertyrrrrrrrr[rvrzrrrrrrrrNsW 1 43#:>'9 4rrcUqg)z@Set the global stash socket path (called during initialization).N)_stash_socket_path)paths rset_stash_socket_pathrs rcSSKn[c/URRS5nU(aU$[ S5e[$)zGet the stash socket path.rNGUNICORN_DIRTY_SOCKETz\Stash socket path not configured. Make sure dirty_workers > 0 and dirty_apps are configured.)osrenvironr[r)rrs rget_stash_socket_pathrsA !zz~~56 K I   rcn[[SS5nUc [5n[U5nU[lU$)z*Get or create a thread-local stash client. stash_clientN)getattr _thread_localrr1r)rr4s r _get_clientrs4 ]ND 9F ~+- [)%+ " Mrc8[5RXU5 g)zStore a value in a table.N)rri)r`r.rSs rririsMe%(rc6[5RXU5$)zRetrieve a value from a table.)rr[)r`r.rms rr[r[s =  U 11rc4[5RX5$)zDelete a key from a table.)rrqr`r.s rrqrq =   ++rc4[5RX5$)zGet all keys in a table.)rrv)r`rTs rrvrvs =  e --rc6[5RU5 g)zDelete all entries in a table.N)rrzr`s rrzrzsMrc4[5RU5$)zGet information about a table.)rr}rs rr}r}s =  e $$rc6[5RU5 g)zEnsure a table exists.N)rrrs rrrsMrc4[5RX5$)zCheck if a table or key exists.)rrrs rrrrrc6[5RU5 g)zDelete an entire table.N)rrrs rrrsMu%rc2[5R5$)zList all tables.)rrrrrrrs =   !!rc4[5RU5$)z%Get a dict-like interface to a table.)rr`)rs rr`r`s =  t $$rr)(rr7r=errorsrprotocolrrrrr r r r r rrrrrr+r1rlocalrrrrrrir[rqrvrzr}rrrrr`rrrrs *X      //AjABJBqqhF4F4\!  ) 2 , .  %  , & " %r