σ ίόΪ\c@`s‘ddlmZmZmZddlZddlZejddkrWddlmZmZddl m Z ddl m Z ddlmZddlmZdd lmZmZmZmZdd lmZeZeZeZeZe Z!e Z"d e#fd „ƒYZ$ddl%Z%d „Z&d„Z'd„Z(d„Z)d„Z*ej+Z,d„Z-nejddkr‘ddl.m-Z-dd l/mZmZmZmZddl0mZmZddl1mZddl2m Z ddl1m)Z)ddl3m*Z*ddlm4Zddl5mZdd l6mZeZeZe7Zddl%m8Z&ddl%m9Z'e!Z!e"Z"e$Z$d„Z(ej:j;ƒZ,e,j<ej=ƒnddl>Z>e>j?ƒj@ƒdkZAej>jBdƒZCyddlDmEZEWneFeGfk rϊeHZEnXyddlImJZJWn!eFk r2ddlJmJZJnXydd lKmLZLWnCeFk rŒddlMZMdd!lKmNZNd"eOfd#„ƒYZLnXdS($i(tprint_functiontdivisiontabsolute_importNi(tQueuetEmpty(tBytesIO(t get_ident(t getargspec(tescape(tIteratortMappingtSettMutableMapping(tgcdtStopAsyncIterationcB`seZRS((t__name__t __module__(((s8lib/python2.7/site-packages/distributed/compatibility.pyRscC`s2tjdt|ƒƒ}|jƒ}|jƒ|S(Ntfileobj(tgziptGzipFileRtreadtclose(tbtftresult((s8lib/python2.7/site-packages/distributed/compatibility.pytgzip_decompresss  cC`sUtƒ}tjd|ddƒ}|j|ƒ|jƒ|jdƒ|jƒ}|S(NRtmodetwi(RRRtwriteRtseekR(RtbioRR((s8lib/python2.7/site-packages/distributed/compatibility.pyt gzip_compress#s     cC`s+t|dƒo*t|dƒo*|jdkS(NtqueueRR(thasattrR(to((s8lib/python2.7/site-packages/distributed/compatibility.pytisqueue,scC`sdS(N((((s8lib/python2.7/site-packages/distributed/compatibility.pytinvalidate_caches1scC`s,ddl}|jj|ƒ\}}|dS(Nis.pyc(tostpathtsplitext(R&R%tnametext((s8lib/python2.7/site-packages/distributed/compatibility.pytcache_from_source4s cC`stS(N(tFalse(tfunc((s8lib/python2.7/site-packages/distributed/compatibility.pytiscoroutinefunction<si(R-(treload(R$(R*(tgetfullargspec(t decompress(tcompresscC`s t|tƒS(N(t isinstanceR(R"((s8lib/python2.7/site-packages/distributed/compatibility.pyR#Vstpypytwin(tJSONDecodeError(tsingledispatch(tfinalize(trefR7cB`sΙeZdZd ZiZeZejƒZ eZ eZ ddd„ƒYZ d„Z dd„Zd„Zd„Zed„ƒZed„ƒZejd „ƒZd „Zed „ƒZed „ƒZRS(s6Class for finalization of weakrefable objects finalize(obj, func, *args, **kwargs) returns a callable finalizer object which will be called when obj is garbage collected. The first time the finalizer is called it evaluates func(*arg, **kwargs) and returns the result. After this the finalizer is dead, and calling it just returns None. When the program exits any remaining finalizers for which the atexit attribute is true will be run in reverse order of creation. By default atexit is true. t_InfocB`seZdZRS(tweakrefR,targstkwargstatexittindex(R:R,R;R<R=R>(RRt __slots__(((s8lib/python2.7/site-packages/distributed/compatibility.pyR9scO`s₯|js1ddl}|j|jƒtt_n|jƒ}t||ƒ|_||_ ||_ |pjd|_ t|_t |jƒ|_||j|t _registryt_dirty(tselftobjR,R;R<R=tinfo((s8lib/python2.7/site-packages/distributed/compatibility.pyt__init__s        cC`sE|jj|dƒ}|rA|j rA|j|j|jp=iŽSdS(s^If alive then mark as dead and return func(*args, **kwargs); otherwise return NoneN(RGtpopRDt _shutdownR,R;R<(RIt_RK((s8lib/python2.7/site-packages/distributed/compatibility.pyt__call__’scC`sh|jj|ƒ}|o!|jƒ}|dk rd|jj|dƒrd||j|j|jp`ifSdS(sbIf alive then mark as dead and return (obj, func, args, kwargs); otherwise return NoneN(RGtgetR:RDRMR,R;R<(RIRKRJ((s8lib/python2.7/site-packages/distributed/compatibility.pytdetach©s!cC`sS|jj|ƒ}|o!|jƒ}|dk rO||j|j|jpKifSdS(sQIf alive then return (obj, func, args, kwargs); otherwise return NoneN(RGRQR:RDR,R;R<(RIRKRJ((s8lib/python2.7/site-packages/distributed/compatibility.pytpeek±s cC`s ||jkS(sWhether finalizer is alive(RG(RI((s8lib/python2.7/site-packages/distributed/compatibility.pytaliveΉscC`s%|jj|ƒ}t|ƒo$|jS(s*Whether finalizer should be called at exit(RGRQtboolR=(RIRK((s8lib/python2.7/site-packages/distributed/compatibility.pyR=ΎscC`s.|jj|ƒ}|r*t|ƒ|_ndS(N(RGRQRUR=(RItvalueRK((s8lib/python2.7/site-packages/distributed/compatibility.pyR=ΔscC`sƒ|jj|ƒ}|o!|jƒ}|dkrMdt|ƒjt|ƒfSdt|ƒjt|ƒt|ƒjt|ƒfSdS(Ns<%s object at %#x; dead>s!<%s object at %#x; for %r at %#x>(RGRQR:RDttypeRtid(RIRKRJ((s8lib/python2.7/site-packages/distributed/compatibility.pyt__repr__Κs    cC`sgg|jjƒD]!\}}|jr||f^q}|jdd„ƒg|D]\}}|^qQS(NtkeycS`s |djS(Ni(R>(titem((s8lib/python2.7/site-packages/distributed/compatibility.pytΫt(RGtitemsR=tsort(tclsRtitL((s8lib/python2.7/site-packages/distributed/compatibility.pyt_select_for_exitΧs7cC`st}zΨ|jrέddl}|jƒr=t}|jƒnd}x—trΩ|dksatjry|j ƒ}tt_n|sƒPn|j ƒ}y |ƒWn$t k rΐt j t jƒŒnX||jksFt‚qFWnWdtt_|rύ|jƒnXdS(Ni(R+RGtgct isenabledRCtdisableRDR7RHRcRMt Exceptiontsyst excepthooktexc_infotAssertionErrorRNtenable(R`t reenable_gcRdtpendingR((s8lib/python2.7/site-packages/distributed/compatibility.pyRBήs.            ((N(RRt__doc__R?RGR+RNt itertoolstcountRFRHR@R9RLRDRPRRRStpropertyRTR=tsetterRYt classmethodRcRB(((s8lib/python2.7/site-packages/distributed/compatibility.pyR7ts$       (Pt __future__RRRtloggingRht version_infoRRtioRtthreadRtget_thread_identitytinspectRtcgiRt html_escapet collectionsR R R R t fractionsR R.tunicodeRCtPY2R+tPY3tOSErrortConnectionRefusedErrortFileExistsErrorRgRRRRR#R$R*t _levelNamest logging_namesR-tasynciotcollections.abcR t importlibt threadingtimportlib.utilR/thtmltmathtstrR0R1t _levelToNametcopytupdatet _nameToLeveltplatformtpython_implementationtlowertPYPYt startswithtWINDOWSt json.decoderR5t ImportErrortAttributeErrort ValueErrort functoolsR6R:R7RpR8tobject(((s8lib/python2.7/site-packages/distributed/compatibility.pyts€  "       "