+ j5NRt^RIt^RIt^RIHt^RIHtHtHtH t H t H t H t H t HtHtHtHt!RR]4t!RR]4t!RR ]4t!R R 4t!R R 4t]P.!4tRsRtRtRtRtRRltRtRRlt Rt!Rt"Rt#RRlt$Rt%Rt&Rt'R#)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]tRt^EtRtRtR#) StashErrorz$Base exception for stash operations.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__rI/var/www/idalgo/venv/lib/python3.14/site-packages/gunicorn/dirty/stash.pyrrEs.rrc6aa]tRt^ItoRtV3RltRtVtV;t#)StashTableNotFoundErrorz#Raised when a table does not exist.c8<Wn\SV` RV 24R#)zStash table not found: N) table_namesuper__init__)selfr __class__s&&rr StashTableNotFoundError.__init__Ls$ 2:,?@r)r rrrrrrr__classdictcell__ __classcell__r! __classdict__s@@rrrIs-AArrc6aa]tRt^QtoRtV3RltRtVtV;t#)StashKeyNotFoundErrorz,Raised when a key does not exist in a table.cJ<WnW n\SV` RV RV 24R#)zKey not found in z: N)rkeyrr)r rr+r!s&&&rrStashKeyNotFoundError.__init__Ts($ ,ZL3%@Ar)r+rr#r&s@@rr)r)Qs6BBrr)ca]tRt^ZtoRtRRltRtRtRtRRlt Rt RR lt R t RR lt R tR tRtRRltRtRtRtRtRtRtRtVtR#) StashClientz` Client for stash operations. Communicates with the arbiter which stores all tables in memory. c `WnW nRVn\P!4VnR#)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 r0r1s&&&rrStashClient.__init__as$'  ^^% rc >\\P!44#)zGenerate a unique request ID.)struuiduuid4r s&r_get_request_idStashClient._get_request_idns4::<  rc ^RIpVPeR#VPVPVP4VnVPP VP 4VPP VP4R# TP\3dpRTn\RT 24ThRp?ii;i)z Establish connection to arbiter.NzFailed to connect to arbiter: ) socketr2AF_UNIX SOCK_STREAM settimeoutr1connectr0errorOSErrorr)r r?es& r_connectStashClient._connectrs :: !  Jv~~v7I7IJDJ JJ ! !$,, / JJ  t// 0 g& JDJ=aSAB I JsA5B B?$B::B?c VPe%VPP4RVnR#R# \dLi;i)zClose the connection.N)r2close Exceptionr;s&r_closeStashClient._closesC :: !    "DJ "  s5 AANc  vVP;_uu_4VPfVP4VP4p\ WaVW4VR7p\ P !VPV4\ P!VP4pVPR4p V \ P8XdVPR4uuRRR4#V \ P8XdfVPR/4p V PRR4p V PRR 4p V R 8Xd \V4hV R 8Xd \W#4h\V 4h\R V 24h \d<p TP4\!T \4'dh\R T 24T hRp ? ii;i +'giR#;i)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+valuepatterntyperesultrD error_typermessagez Unknown errorrr)zUnexpected response type: zStash operation failed: )r5r2rGr<rr write_message read_messagegetMSG_TYPE_RESPONSEMSG_TYPE_ERRORrr)rrKrL isinstance)r optabler+rOrP request_idrTresponsemsg_type error_inforS error_msgrFs&&&&&& r_executeStashClient._executesoZZZzz! --/J(gG  H++DJJ@(55djjA#<</}>>>#<<1!Z"!=!==!)gr!:J!+ l!KJ *y/ JI!%>>5e<<!%<<3E??$Y//$'A(%LMM H a,, #;A3!?@aG  H=ZZs1>F'A7EBE F$)6FF$$F'' F8 c 6VP\WVR7R#)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+rON)rbr)r r\r+rOs&&&&rputStashClient.puts lE% @rc XVP\WR7# \dTu#i;i)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+)rbrr))r r\r+defaults&&&&rrWStashClient.gets. ==u=> >$ N s  ))c 0VP\WR7#)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 rh)rbrr r\r+s&&&rdeleteStashClient.delete}}_e}==rc 0VP\WR7#)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 rP)rbr)r r\rPs&&&rkeysStashClient.keyss}}]E}CCrc 2VP\V4R#)z= Delete all entries in a table. Args: table: Table name N)rbrr r\s&&rclearStashClient.clears ne,rc .VP\V4#)zm Get information about a table. Args: table: Table name Returns: Dict with table info (size, etc.) )rbr rus&&rinfoStashClient.infos}}]E22rc 2VP\V4R#)z Ensure a table exists (create if not exists). This is idempotent - calling it multiple times is safe. Args: table: Table name N)rbr rus&&rensureStashClient.ensure s ou-rc 0VP\WR7#)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 rh)rbr rls&&&rexistsStashClient.existsrorc 2VP\V4R#)z6 Delete an entire table. Args: table: Table name N)rbr rus&&r delete_tableStashClient.delete_table$s +U3rc .VP\R4#)z4 List all tables. Returns: List of table names )rbr r;s&rtablesStashClient.tables-s}}_b11rc \W4#)ze Get a dict-like interface to a table. Args: name: Table name Returns: StashTable instance ) StashTable)r names&&rr\StashClient.table6s$%%rc VP;_uu_4VP4RRR4R# +'giR#;i)zClose the client connection.N)r5rLr;s&rrJStashClient.closeBs ZZZ KKMZZZs 0 A cV#Nrr;s&r __enter__StashClient.__enter__Gs rc&VP4R#r)rJ)r exc_typeexc_valexc_tbs&&&&r__exit__StashClient.__exit__Js  r)r5r2r0r1)g>@)NNNr)rrrrrrr<rGrLrbrerWrmrrrvryr|rrrr\rJrrrr$r's@rr.r.Zss &! J0Hl A" > D- 3 . >42 & rr.ca]tRtRtoRtRt]R4tRtRt Rt Rt R t R t RR ltRR ltRtRtRtRtVtR #)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]) cWnW nR#r_client_name)r clientrs&&&rrStashTable.__init__^s   rc VP#)z Table name.)rr;s&rrStashTable.namebszzrcVPPVPV4pVf8VPPVPV4'g \ V4hV#r)rrWrrKeyError)r r+rRs&& r __getitem__StashTable.__getitem__gsK!!$**c2 ><<&&tzz377sm# rcRVPPVPW4R#r)rrer)r r+rOs&&&r __setitem__StashTable.__setitem__os S0rctVPPVPV4'g \V4hR#r)rrmrrr r+s&&r __delitem__StashTable.__delitem__rs,||""4::s333- 4rcNVPPVPV4#r)rrrrs&&r __contains__StashTable.__contains__vs||""4::s33rc^\VPPVP44#r)iterrrrrr;s&r__iter__StashTable.__iter__ys DLL%%djj122rcpVPPVP4pVPR^4#)size)rryrrW)r rys& r__len__StashTable.__len__|s+||  ,xx""rNc NVPPVPW4#)zGet value with default.)rrWr)r r+ris&&&rrWStashTable.gets|| C99rc PVPPVPVR7#)z-Get all keys, optionally filtered by pattern.rq)rrrr)r rPs&&rrrStashTable.keyss ||  W ==rc PVPPVP4R#)zDelete all entries.N)rrvrr;s&rrvStashTable.clears 4::&rc# "VPPVP4F,pWPPVPV43xK. R#5i)z Iterate over (key, value) pairs.NrrrrrWrs& ritemsStashTable.itemss@<<$$TZZ0C||'' C88 81sAAc# "VPPVP4F+pVPPVPV4xK- R#5i)zIterate over values.Nrrs& rvaluesStashTable.valuess=<<$$TZZ0C,,""4::s3 31sAArr)rrrrrrpropertyrrrrrrrrWrrrvrrrr$rs@rrrNs_ 1 43#:>'9 44rrc VsR#)z@Set the global stash socket path (called during initialization).N)_stash_socket_path)paths&rset_stash_socket_pathrs rc^RIp\f1VPPR4pV'dV#\ R4h\#)zGet the stash socket path.NGUNICORN_DIRTY_SOCKETz\Stash socket path not configured. Make sure dirty_workers > 0 and dirty_apps are configured.)osrenvironrWr)rrs rget_stash_socket_pathrsA !zz~~56 K I   rcp\\RR4pVf!\4p\V4pV\nV#)z*Get or create a thread-local stash client. stash_clientN)getattr _thread_localrr.r)rr0s r _get_clientrs4 ]ND 9F ~+- [)%+ " Mrc:\4PWV4R#)zStore a value in a table.N)rre)r\r+rOs&&&rreresMe%(rc6\4PWV4#)zRetrieve a value from a table.)rrW)r\r+ris&&&rrWrWs =  U 11rc4\4PW4#)zDelete a key from a table.)rrmr\r+s&&rrmrm =   ++rc4\4PW4#)zGet all keys in a table.)rrr)r\rPs&&rrrrrs =  e --rc8\4PV4R#)zDelete all entries in a table.N)rrvr\s&rrvrvsMrc4\4PV4#)zGet information about a table.)rryrs&rryrys =  e $$rc8\4PV4R#)zEnsure a table exists.N)rr|rs&rr|r|sMrc4\4PW4#)zCheck if a table or key exists.)rrrs&&rrrrrc8\4PV4R#)zDelete an entire table.N)rrrs&rrrsMu%rc2\4P4#)zList all tables.)rrrrrrrs =   !!rc4\4PV4#)z%Get a dict-like interface to a table.)rr\)rs&rr\r\s =  t $$rr)(rr3r9errorsrprotocolrrrrrrr r r r r rrrr)r.rlocalrrrrrrerWrmrrrvryr|rrrr\rrrrs *X      //AjABJBqqhF4F4\!  ) 2 , .  %  , & " %r