/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/
/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm
NameSizeModeActions
attributes.py671370644editdlrm
attributes.pyc621290644editdlrm
attributes.pyo618510644editdlrm
base.py148640644editdlrm
base.pyc155580644editdlrm
base.pyo155580644editdlrm
collections.py526140644editdlrm
collections.pyc634480644editdlrm
collections.pyo632260644editdlrm
dependency.py465560644editdlrm
dependency.pyc296240644editdlrm
dependency.pyo295330644editdlrm
deprecated_interfaces.py207510644editdlrm
deprecated_interfaces.pyc227760644editdlrm
deprecated_interfaces.pyo227760644editdlrm
descriptor_props.py282010644editdlrm
descriptor_props.pyc322160644editdlrm
descriptor_props.pyo322160644editdlrm
dynamic.py146660644editdlrm
dynamic.pyc153390644editdlrm
dynamic.pyo153390644editdlrm
evaluator.py54410644editdlrm
evaluator.pyc78190644editdlrm
evaluator.pyo78190644editdlrm
events.py944090644editdlrm
events.pyc1036650644editdlrm
events.pyo1036650644editdlrm
exc.py66100644editdlrm
exc.pyc88380644editdlrm
exc.pyo88380644editdlrm
identity.py102990644editdlrm
identity.pyc151090644editdlrm
identity.pyo151090644editdlrm
instrumentation.py181310644editdlrm
instrumentation.pyc216330644editdlrm
instrumentation.pyo215440644editdlrm
interfaces.py257660644editdlrm
interfaces.pyc302340644editdlrm
interfaces.pyo302340644editdlrm
loading.py322360644editdlrm
loading.pyc205740644editdlrm
loading.pyo205490644editdlrm
mapper.py1283440644editdlrm
mapper.pyc1004120644editdlrm
mapper.pyo1001980644editdlrm
path_registry.py92620644editdlrm
path_registry.pyc132560644editdlrm
path_registry.pyo132560644editdlrm
persistence.py656520644editdlrm
persistence.pyc467860644editdlrm
persistence.pyo467860644editdlrm
properties.py110430644editdlrm
properties.pyc121110644editdlrm
properties.pyo121110644editdlrm
query.py1725900644editdlrm
query.pyc1550140644editdlrm
query.pyo1549360644editdlrm
relationships.py1244420644editdlrm
relationships.pyc1053180644editdlrm
relationships.pyo1052930644editdlrm
scoping.py63930644editdlrm
scoping.pyc76800644editdlrm
scoping.pyo76800644editdlrm
session.py1287540644editdlrm
session.pyc1201170644editdlrm
session.pyo1199380644editdlrm
state.py310440644editdlrm
state.pyc322940644editdlrm
state.pyo322380644editdlrm
strategies.py846020644editdlrm
strategies.pyc630190644editdlrm
strategies.pyo626680644editdlrm
strategy_options.py555050644editdlrm
strategy_options.pyc527300644editdlrm
strategy_options.pyo525960644editdlrm
sync.py55360644editdlrm
sync.pyc46280644editdlrm
sync.pyo46280644editdlrm
unitofwork.py247350644editdlrm
unitofwork.pyc245650644editdlrm
unitofwork.pyo244890644editdlrm
util.py448590644editdlrm
util.pyc443630644editdlrm
util.pyo442110644editdlrm
__init__.py95420644editdlrm
__init__.pyc107590644editdlrm
__init__.pyo107590644editdlrm
Edit: /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyo (24489B)
 4]c@sxdZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z d Z d e fd YZ d e fd YZ de fdYZde fdYZde efdYZdefdYZdefdYZdefdYZdefdYZdefdYZdefdYZd S(!sThe internals for the unit of work system. The session's flush() process passes objects to a contextual object here, which assembles flush tasks based on mappers and their properties, organizes them in order of dependency, and executes. i(t attributes(texc(t persistence(tutili(tevent(t topologicalcs|jfd}fd}fd}tj|d|dtdttj|d|dtdttj|d|dtdtd S( s\Establish event listeners on object attributes which handle cascade-on-set/append. cs|dkrdS|j}|r|jr8|jdn|jjj}tj|}|j j r|j s~|j kr|j | r|j|qn|S(Nscollection append(tNonetsessiont_warn_on_eventst_flush_warningtmanagertmappert_propsRtinstance_statet_cascadet save_updatetcascade_backrefstkeyt_contains_statet_save_or_update_state(tstatetitemt initiatortsesstpropt item_state(R(sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pytappend s    cs|dkrdS|j}|jjj}|rZ|jrZ|j|jrPdndn|dk r|tj k r|tj k r|j j rtj |}|jj|r|r||jkr|j|qt|_qndS(Nscollection removesrelated attribute delete(RRR R R RR tuselistRt NEVER_SETtPASSIVE_NO_RESULTRt delete_orphanR t _is_orphant_newtexpungetTruet_orphaned_outside_of_session(RRRRRR(R(sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pytremove6s"     cs-||kr|S|j}|r)|jr8|jdn|jjj}|dk rtj|}|j j r|j s|j kr|j | r|j|qn|dk r)|tjk r)|tjk r)|j jr)tj|}||jkr&|jj|r&|j|q&q)n|S(Nsrelated attribute set(RRR R R R RRR RRRRRRRRRR RR!(RtnewvaluetoldvalueRRRtnewvalue_statetoldvalue_state(R(sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pytset_Xs,        RtrawtretvalR$tsetN(RRtlistenR"(t descriptorRRR$R)((RsL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyttrack_cascade_eventss "%tUOWTransactioncBseZdZedZdZdZdZdZe j dZ dZ dZ eeeddd Zd Zd Zejd Zd ZdZdZdZdZRS(cCsv||_i|_tjt|_tjt|_i|_i|_t|_ i|_ tjd|_ dS(NcSsttfS(N(R,(((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pytt( RRRt defaultdictR,tdepstmapperstpresort_actionstpostsort_actionst dependencieststatestpost_update_states(tselfR((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt__init__s      cCs t|jS(N(tboolR9(R;((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pythas_workscCsR|jrNy|j|tjWqNtjk rJ|jj|gtSXnt S(sVreturn true if the given state is expired and was deleted previously. ( texpiredt _load_expiredRt PASSIVE_OFFtorm_exctObjectDeletedErrorRt_remove_newly_deletedR"tFalse(R;R((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pytwas_already_deleteds cCs||jko|j|dS(sWreturn true if the given state is marked as deleted within this uowtransaction.i(R9(R;R((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt is_deletedscCs6||jkr|j|S||j|<}|SdS(N(R(R;Rt callable_tret((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pytmemos cCs(|j|d}|tf|j|wsiiN(R"REtlistR6tvaluestexecuteRt find_cyclesR8R7tcyclesRQRtdisabledt issupersetR$RdR,t difference(R;RItactionRtconverttedgeRwta((R;sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt_generate_actions^s:  %   !(.cCs|j}|jraxvtj|j|D]/}x&|rY|j}|j||q4Wq+Wn-x*tj|j|D]}|j|qwWdS(N( RRRtsort_as_subsetsR8tpoptexecute_aggregatetsortR(R;R7R)tnR((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs    cCs|js dSt|j}td|jjD}|j|}|rc|jj|n|r||jj|ndS(smark processed objects as clean / deleted after a successful flush(). this method is called within the flush() method after the execute() method has succeeded and the transaction has been committed. Ncss'|]\}\}}|r|VqdS(N((RR}RKRe((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pys s(R9R,titemsRRRDt_register_persistent(R;R9tisdeltother((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pytfinalize_flush_changess N(t__name__t __module__R<tpropertyR>RFRGRJRLRtPASSIVE_NO_INITIALIZERYR[R^RERRhRmRcRtmemoized_propertyR{R~RRRR(((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR0s, -   .        4 tIterateMappersMixincBseZdZRS(cs@jr/tfdjjjDSjjjSdS(Nc3s+|]!}j|jfr|VqdS(N(R{tdependency_processor(Rtm(R;tuow(sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pys s(R]titerRtparentRR (R;R((R;RsL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt_mapperss  (RRR(((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRsR\cBs eZdZdZdZRS(RR]t processedtsetup_flush_actionscCs+||_||_t|_t|_dS(N(RR]R,RRER(R;RR]((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR<s   cCsUt}t}xz|j|D]i}x`|j|j|jD]E}|j|\}}|sB|rw|j|q|j|qBqBWq"W|r|jj|||jj |n|r|jj |||jj |n|s|rM|j rI|jj ||t s-|jj ||trI|jj|t |_ nt StSdS(N(R,RR5RRR9RdRtpresort_deletesRjt presort_savesRtprop_has_changesR"REtper_property_flush_actions(R;Rt delete_statest save_statesR RRKRe((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs2        (RR]RR(RRt __slots__R<R(((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR\s  t PostSortReccBs eZdZdZdZRS(RcGsR|f|}||jkr'|j|Stj||j|<}t|_|SdS(N(R7tobjectt__new__RER(tclsRtargsRRI((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs    cCs|j|dS(N(R(R;Rtrecs((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs(R(RRRRR(((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs t ProcessAllcBs;eZdZdZdZdZdZdZRS( RRKR]cCs9||_||_||_|j|jjj|dS(N(RRKR]R4RRiRd(R;RRRKR]((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR<s    cCsE|j|}|jr.|jj||n|jj||dS(N(t _elementsRKRtprocess_deletest process_saves(R;RR9((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs cCs tgS(N(R(R;R((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRscCsd|jj|j|jfS(Ns%s(%s, isdelete=%s)(t __class__RRRK(R;((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt__repr__%s ccsgx`|j|D]O}xF|j|D]7}|j|\}}||jkr$| r$|Vq$q$WqWdS(N(RR5R9RK(R;RR RRKRe((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR,s (RRKR](RRRR<RRRR(((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR s     t PostUpdateAllcBs eZdZdZdZRS(R RKcCs||_||_dS(N(R RK(R;RR RK((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR<7s cCsf|j|j\}}g|D]&}|j|d|jkr|^q}tj|j|||dS(Ni(R:R R9RKRt post_update(R;RR9RlR}((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR;s3(R RK(RRRR<R(((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR4s RncBs2eZdZdZdZdZdZRS(R cCs ||_dS(N(R (R;RR ((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR<Es cCs,tj|j|j|jtt|dS(N(Rtsave_objR RRE(R;R((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRIsc cst|j|jtt}|jj}t||}x8|D]0}t||}|jj||f|Vq@Wx=|j |jD]+}|j ||}|j ||tqWdS(N( RRR RERiRotSaveUpdateStateR8RdR4R~R( R;RR9Rit delete_allRRRwtstates_for_prop((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRPs   cCsd|jj|jfS(Ns%s(%s)(RRR (R;((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRas(R (RRRR<RRR(((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRnBs    RocBs2eZdZdZdZdZdZRS(R cCs ||_dS(N(R (R;RR ((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR<hs cCs,tj|j|j|jtt|dS(N(Rt delete_objR RR"RE(R;R((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRlsc cst|j|jtt}|jj}t||}x8|D]0}t||}|jj ||f|Vq@Wx=|j |jD]+}|j ||}|j ||tqWdS(N( RRR R"RERiRnt DeleteStateR8RdR4R~R( R;RR9Ritsave_allRRRwR((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRss   cCsd|jj|jfS(Ns%s(%s)(RRR (R;((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs(R (RRRR<RRR(((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRoes    t ProcessStatecBs)eZdZdZdZdZRS(RRKRcCs||_||_||_dS(N(RRKR(R;RRRKR((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR<s  c Cs|j}|j}|j}g|D]9}|j|kr"|j|kr"|j|kr"|^q"}|j||jgg|D]}|j^q~}|r|j||n|j||dS(N(RRRKtdifference_updateRRR( R;RRtcls_RRKtrtour_recsR9((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs     &cCs,d|jj|jtj|j|jfS(Ns%s(%s, %s, delete=%s)(RRRRat state_strRRK(R;((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs  (RRKR(RRRR<RR(((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs  RcBs)eZdZdZdZdZRS(RR cCs||_|jj|_dS(N(RR Ri(R;RR((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR<s cCs|j}|j}g|D]*}|j|kr|j|kr|^q}|j|tj||jgg|D]}|j^qo|dS(N(RR RRRR(R;RRRR RR((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs   7 cCs d|jjtj|jfS(Ns%s(%s)(RRRaRR(R;((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs (RR (RRRR<RR(((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs  RcBs)eZdZdZdZdZRS(RR cCs||_|jj|_dS(N(RR Ri(R;RR((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR<s c Cs|j}|j}g|D]*}|j|kr|j|kr|^q}|j||jgg|D]}|j^qf}tj|g|D]}|j|dr|^q|dS(Ni(RR RRRRR9( R;RRRR RRR9R}((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs  7 &cCs d|jjtj|jfS(Ns%s(%s)(RRRaRR(R;((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs (RR (RRRR<RR(((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs  N(t__doc__R2RRRBRRRaRRR/RR0RR\RRRRnRoRRR(((sL/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyts( i= 2(###