P'^c@sddlZddlZddlmZmZmZddlmZddlm Z m Z ddl m Z ddl mZddlmZdd lmZmZmZdd lmZdd lmZdZedZdZeeedZedZeeedZedZdej fdYZ!defdYZ"e"Z#edZ$ee%dZ&dS(iN(tmemoizetpost_processingtContextDecorator(tDEFAULT_DB_ALIAS(tFt Expression(t StrictVersioni(tsettings(t get_prefix(t redis_clientthandle_connection_failuret load_script(tcache_invalidated(tqueue_when_in_transactiontinvalidate_objtinvalidate_modeltinvalidate_alltno_invalidationcCs&tjd}t|tdkS(Nt redis_versions4.0(R tinfoR(R((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pytredis_can_unlinkscGs-trtjd|n tj|dS(NtUNLINK(RR texecute_commandtdelete(tkeys((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pytinvalidate_keyss c Cstjstj rdS|jj}td|jjt|j fgd|g}t ddt d|gd|jjt j |dtgtjd|d |dS( Nt _cond_dnfstdbst invalidatetstripRtargstdefaulttsendertobj_dict(RtactiveRtCACHEOPS_ENABLEDt_metatconcrete_modelRtdb_tabletlisttitemsR RtjsontdumpststrR tsend(tmodelR!tusingtprefix((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pytinvalidate_dict s 3 cCs/|jjj}t|t||d|dS(sF Invalidates caches that can possibly be influenced by object R.N(t __class__R$R%R0t get_obj_dict(tobjR.R-((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pyR.scCstjstj rdS|jj}td|jjgd|g}tj d||jjf}|rtj |}t ||}t |nt jd|dddS(s Invalidates all caches for given model. NOTE: This is a heavy artillery which uses redis KEYS request, which could be relatively slow on large datasets. NttablesRs %sconj:%s:*R R!(RR"RR#R$R%RR&R RtsunionR'RR R,tNone(R-R.R/t conjs_keyst cache_keysR((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pyR6s ! cCs;tjstj rdStjtjdddddS(NR R!( RR"RR#R tflushdbR R,R6(((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pyRLs tInvalidationStatecBseZdZRS(cCs d|_dS(Ni(tdepth(tself((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pyt__init__Us(t__name__t __module__R=(((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pyR:Tst_no_invalidationcBs2eZeZdZdZedZRS(cCs|jjd7_dS(Ni(tstateR;(R<((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pyt __enter__[scCs|jjd8_dS(Ni(RAR;(R<ttypetvaluet traceback((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pyt__exit__^scCs |jjS(N(RAR;(R<((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pyR"as(R>R?R:RARBRFtpropertyR"(((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pyR@Xs   cCstd|jjDS(Ncss'|]}t|tjs|VqdS(N(t isinstanceRtCACHEOPS_SKIP_FIELDS(t.0tf((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pys ls(ttupleR$tfields(R-((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pytserializable_fieldsjsccs|xut|D]g}t||j}|dkrB|jdfVq t|ttfr]q q |j|j|fVq WdS(N(RNtgetattrtattnameR6RHRRtget_prep_value(R-R3tfieldRD((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pyR2os (RRRR('R)t threadingtfuncyRRRt django.dbRtdjango.db.models.expressionsRRtdistutils.versionRtconfRtshardingRtredisR R R tsignalsR t transactionR t__all__RRR0RRRtlocalR:R@RRNtdictR2(((s7/tmp/pip-unpacked-wheel-CLcuMp/cacheops/invalidation.pyts4