]j{"SrSrSSKJr SSKrSSKrSSKrSSKJr SSK r SSKrSSKrSr\"5r"SS\ R&5r"SS 5rg!\ a SSK r NCf=f!\ a SSK r NNf=f) a] Vendoring of pickleshare, reduced to used functionalities. --- PickleShare - a small 'shelve' like datastore with concurrency support Like shelve, a PickleShareDB object acts like a normal dictionary. Unlike shelve, many processes can access the database simultaneously. Changing a value in database is immediately visible to other processes accessing the same database. Concurrency is possible because the values are stored in separate files. Hence the "database" is a directory where *all* files are governed by PickleShare. Example usage:: from pickleshare import * db = PickleShareDB('~/testpickleshare') db.clear() print "Should be empty:",db.items() db['hello'] = 15 db['aku ankka'] = [1,2,313] db['paths/are/ok/key'] = [1,(5,46)] print db.keys() del db['aku ankka'] This module is certainly not ZODB, but can be used for low-load (non-mission-critical) situations where tiny code size trumps the advanced features of a "real" object database. Installation guide: pip install pickleshare Author: Ville Vainio License: MIT open source license. z0.7.5)PathNc<S[[U5S-5-SS$)Nz%02x)abshash)keys Y/home/mande/repo/quber/.venv/lib/python3.13/site-packages/IPython/external/pickleshare.py gethashfiler :s! ScS) )23 //c\rSrSrSrSrSrSrSr\ S4Sjr S r S r S r S rSSjrSrSrSrSSjrSrSrSrg ) PickleShareDBAz5The main 'connection' object for PickleShare databasec[U[5(d [U5n[RR [RR U55n[ U5UlURR5(dURRSS9 0Ul g![a)nUR[R:waeSnAN6SnAff=f)z9Return a db object that will manage the specied directoryTparentsN) isinstancestrospathabspath expanduserrrootis_dirmkdirOSErrorerrnoEEXISTcache)selfres r __init__PickleShareDB.__init__Ds$$$t9Dwwrww11$78J yy!!  -   77ell*+ s B.. C!8CC!cURU- nUR5[RnX R ;a'X0R US:XaUR US$UR S5n[R"UR55nSSS5 WU4UR U'U$![a [ U5ef=f!,(df  N:=f! [ U5e=f)zdb['key'] readingrrbN) rstatST_MTIMErKeyErrorropenpickleloadsread)r r filmtimefobjs r __getitem__PickleShareDB.__getitem__Usii#o HHJt}}-E ** **S/!*i'"3-' 8$AuuS""r cjURUS-5nUR5 [U5=(a US=(d SnURS5(a U/USS-n0nUH(nUR X5 URU5 M* U$![ a [ SUS5 X N2f=f)z A  A cj[URUR55RSS5$)z#Make a key suitable for user's eyes\/)r relative_torreplace)r rbs r _normalizedPickleShareDB._normalizeds'1==+,44T3??r NcUcURRS5nOURRU5nUVs/sH*o3R5(dMUR U5PM, sn$s snf)z+All keys in DB, or all keys matching a glob*)rrglobglobis_filern)r globpatfilesrbs r rUPickleShareDB.keyssY ?IIOOC(EIINN7+E-2BUiik#  #UBBBs A3A3c4[UR55$N)iterrUr s r __iter__PickleShareDB.__iter__sDIIK  r c4[UR55$ry)rWrUr{s r __len__PickleShareDB.__len__s499;r cjU(d0UlUHnURRUS5 M! g)zRemoves all, or specified items from cache Use this after reading a large amount of large objects to free up memory, when you won't be needing the objects for a while. N)rrf)r itemsits r rZPickleShareDB.uncaches*DJB JJNN2t $r cS/S-S/S--S/-nSnSnXnU$![a Of=fXR:a [U5e[R"X45 XSU- nU[U5S- :aUS- nM_)aWait (poll) for a key to get a value Will wait for `maxwaittime` seconds before raising a KeyError. The call exits normally if the `key` field in db gets a value within the timeout period. Use this for synchronizing different processes or for ensuring that an unfortunately timed "db['key'] = newvalue" operation in another process (which causes all 'get' operation to cause a KeyError for the duration of pickling) won't screw up your program logic. g?g?r6r%r)r)timesleeprW)r r maxwaittimewtimestrieswaitedvals r waitgetPickleShareDB.waitgetscUQY&!, i   #sm# JJv} % Um #Fs6{Q& s  ++c[X5$)z)Get a convenient link for accessing items)PickleShareLink)r folders r getlinkPickleShareDB.getlink s t,,r c SUR-$)NzPickleShareDB('%s'))rr{s r __repr__PickleShareDB.__repr__s$tyy00r )rrry)<)__name__ __module__ __qualname____firstlineno____doc__r"r2r=rFrIrMrJrcrgrnrUr|rrZrrr__static_attributes__r r rrAs_?"( +4t#&.* @C!  %@-1r rc0\rSrSrSrSrSrSrSrSr g) rizA shortdand for accessing nested PickleShare data conveniently. Created through PickleShareDB.getlink(), example:: lnk = db.getlink('myobjects/test') lnk.foo = 2 lnk.bar = lnk.foo + 5 cJURR[55 gry)__dict__rAlocals)r dbkeydirs r r"PickleShareLink.__init__ s VX&r cLURSURSS-U-$)Nrrrk)r)r r s r __getattr__PickleShareLink.__getattr__#s)}}T"4==#:S#@3#FGGr c@X RURS-U-'g)Nrk)rr)r r rs r __setattr__PickleShareLink.__setattr__&s+. c!C'(r c  URSnURURSS-5nSURS<SSRUVs/sHn[U5R 5PM sn5<S3$s snf)NrrrPz)rrUjoinrbasename)r rrUks r rPickleShareLink.__repr__)sm ]]4 wwt}}X.56 MM( # HH$7$Qd1g&&($7 8  7s#BrN) rrrrrr"rrrrrr r rrs'H/ r r)r __version__pathlibrrr'rcollections.abcabccollections_abc ImportError collectionscPickler+rsysr objectrIMutableMappingrrrr r rs$L *- 0 H Q1O22Q1h  K*)*s"AA% A"!A"% A21A2