\c.@`spddlmZmZmZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZddlmZddlmZddlmZddlZddlmZd d lmZmZmZmZmZmZd d lm Z d d l!m"Z"ej#Z$e$d krKdZ$ndZ%dZ&dZ'edZ(dZ)edddZ+eddZ,ede-ddZ.edZ/eddZ0edZ1de2fdYZ3ee-de4dZ5d Z6dd!Z7dd"Z8d#Z9e:e;e<e=e>e?e@eAeBeCeDeEeFeGeHeIeJeKeLeMeNeOePeQeReSeTeUeVe-eWeXeYeZe[e:e\e]e^e_e`eaebecedeeg-Zferefjgehne:eiejekelemeneoepeqeresg Zte4d$Zud%e2fd&YZvd'Zwd(Zxd)Zyd*Zzdd+Z{d,Z|gdd-Z}dgd.Z~d/Zd0Zd1Zd2Zd3Zd4Zd5Zd6Zd7Zd8ZiZd9e2fd:YZd;e2fd<YZd=e2fd>YZeZd?e2fd@YZdddAZdBZdCe2fdDYZdEZdFZdGZdHZdIZi dedL6dfdN6dgdP6dhdR6didT6djdV6dkdX6dldZ6dmd\6dnd^6d d_6d d6Zd`ejDZejdaejDejdbejDdcZddZdS(oi(tabsolute_importtdivisiontprint_functionN(tENOENT(tcontextmanager(t import_module(tIntegral(tLock(tWeakValueDictionaryi(tget_named_argst getargspectPY3tunicodet bind_methodtIterator(tget_deps(t key_splittasciisutf-8cG`sMt|dttfr?gt|D]}t||^q&S||SdS(s Apply function inside nested lists >>> inc = lambda x: x + 1 >>> deepmap(inc, [[1, 2], [3, 4]]) [[2, 3], [4, 5]] >>> add = lambda x, y: x + y >>> deepmap(add, [[1, 2], [3, 4]], [[10, 20], [30, 40]]) [[11, 22], [33, 44]] iN(t isinstancetlistRtziptdeepmap(tfunctseqstitems((s)lib/python2.7/site-packages/dask/utils.pyRs &cC`sP|s |Sd}|}x't|tr?|d7}|d}qWt|||S(Nii(RRtndeepmap(Rtseqtnttmp((s)lib/python2.7/site-packages/dask/utils.pythomogeneous_deepmap.s cC`s|dkr)g|D]}||^qS|dkr\g|D]}t|d||^q<St|try||dS||SdS(s Call a function on every element within a nested container >>> def inc(x): ... return x + 1 >>> L = [[1, 2], [3, 4, 5]] >>> ndeepmap(2, inc, L) [[2, 3], [4, 5, 6]] iiN(RRR(RRRtitem((s)lib/python2.7/site-packages/dask/utils.pyR:s  'cg`s!y dVWn|k rnXdS(N((t exceptions((s)lib/python2.7/site-packages/dask/utils.pytignoringMs  cC`s2yt|SWntk r-t|nXdS(srAttempt to import a required dependency. Raises a RuntimeError if the requested module is not available. N(Rt ImportErrort RuntimeError(tmod_namet error_msg((s)lib/python2.7/site-packages/dask/utils.pytimport_requiredUs tc c`sd|jd}tj|d|\}}tj|tj|z |VWdtjj|rtjj|rt j |qt t tj|WdQXnXdS(Nt.tdir( tlstripttempfiletmkstemptostclosetremovetpathtexiststisdirtshutiltrmtreeR tOSError(t extensionR(thandletfilename((s)lib/python2.7/site-packages/dask/utils.pyttmpfile`s    c c`stjd|}z |VWdtjj|rtjj|retttj |WdQXqtttj |WdQXnXdS(NR(( R*tmkdtempR,R/R0R1R R4R2R3R.(R(tdirname((s)lib/python2.7/site-packages/dask/utils.pyttmpdirrs   twc c`sjtd|U}||d|}z|j|Wdy|jWntk rYnXX|VWdQXdS(NR5tmode(R8twriteR-tAttributeError(ttextR5topenR=R7tf((s)lib/python2.7/site-packages/dask/utils.pytfiletexts cc`s7tj}tj|z dVWdtj|XdS(N(R,tgetcwdtchdir(tnew_cwdtold_cwd((s)lib/python2.7/site-packages/dask/utils.pyt changed_cwds    c c`s1t|}t| |VWdQXWdQXdS(N(R;RH(R(R:((s)lib/python2.7/site-packages/dask/utils.pyttmp_cwds cc`s dVdS(N((((s)lib/python2.7/site-packages/dask/utils.pyt noop_contextst IndexCallablecB`s&eZdZdZdZdZRS(s Provide getitem syntax for functions >>> def inc(x): ... return x + 1 >>> I = IndexCallable(inc) >>> I[3] 4 tfncC`s ||_dS(N(RL(tselfRL((s)lib/python2.7/site-packages/dask/utils.pyt__init__scC`s |j|S(N(RL(RMtkey((s)lib/python2.7/site-packages/dask/utils.pyt __getitem__s(RL(t__name__t __module__t__doc__t __slots__RNRP(((s)lib/python2.7/site-packages/dask/utils.pyRKs  ttc c`s |rtntx|jD]\}}ytjtjj|Wntk rbnX||d|}z|j|Wdy|j Wnt k rnXXq&Wt |VxC|D];}tjj |rt ttj|WdQXqqWWdQXdS(s6 Dumps a number of textfiles to disk d - dict a mapping from filename to text like {'a.csv': '1,1 2,2'} Since this is meant for use in tests, this context manager will automatically switch to a temporary current directory, to avoid race conditions when running tests in parallel. R<N(RIRJRR,tmakedirsR/R:R4R>R-R?RR0R R.(tdRAR=t use_tmpdirR7R@RB((s)lib/python2.7/site-packages/dask/utils.pyt filetextss$       cC`sOt|trt|}nt|ttfrKttt|}n|S(s Make nested iterators concrete lists >>> data = [[1, 2], [3, 4]] >>> seq = iter(map(iter, data)) >>> concrete(seq) [[1, 2], [3, 4]] (RRRttupletmaptconcrete(R((s)lib/python2.7/site-packages/dask/utils.pyR\s c C`sddl}t|}|jdg|}|jd|dsJtt|dksbtt||jjs|jj|}n|j |}|j |dd}xKt t |d |dD],\}\}} ||||k|| k@>> pseudorandom(5, [0.5, 0.5], random_state=123) array([1, 0, 0, 1, 1], dtype=int8) >>> pseudorandom(10, [0.5, 0.2, 0.2, 0.1], random_state=5) array([0, 2, 0, 3, 0, 1, 2, 1, 0, 0], dtype=int8) iNiiitdtypeti1( tnumpyRtcumsumtallclosetAssertionErrortlenRtrandomt RandomStatet random_sampletemptyt enumerateR( Rtpt random_statetnptcptxtouttitlowthigh((s)lib/python2.7/site-packages/dask/utils.pyt pseudorandoms  0c`sddl}tfdddddgDsI|jjnjd|d }t|j|d |jj|d f}t ||kst |S( sReturn a list of arrays that can initialize ``np.random.RandomState``. Parameters ---------- n : int Number of arrays to return. random_state : int or np.random.RandomState, optional If an int, is used to seed a new ``RandomState``. iNc3`s|]}t|VqdS(N(thasattr(t.0tattr(Rj(s)lib/python2.7/site-packages/dask/utils.pys stnormaltbetatbytestuniformipiR]i( R_tallRdReRxRt frombuffertuint32treshapeRcRb(RRjRkt random_datatl((Rjs)lib/python2.7/site-packages/dask/utils.pytrandom_state_datas (-cC`s(t|tp't|to'|jS(sj >>> is_integer(6) True >>> is_integer(42.0) True >>> is_integer('abc') False (RRtfloatt is_integer(Ro((s)lib/python2.7/site-packages/dask/utils.pyRs cC`s|tkrtS|tkr tSyt|}Wntk rDtSXy&|jddkogt|t}Wntk rt}nX|r|j rtS|j dkrdn t |j }t |j||dkS(s Does this function take multiple arguments? >>> def f(x, y): pass >>> takes_multiple_arguments(f) True >>> def f(x): pass >>> takes_multiple_arguments(f) False >>> def f(x, y=None): pass >>> takes_multiple_arguments(f) False >>> def f(*args): pass >>> takes_multiple_arguments(f) True >>> class Thing(object): ... def __init__(self, a): pass >>> takes_multiple_arguments(Thing) False iRMiN( tONE_ARITY_BUILTINStFalsetMULTI_ARITY_BUILTINStTrueR t ExceptiontargsRttypetvarargstdefaultstNoneRc(RRtspectis_constructort ndefaults((s)lib/python2.7/site-packages/dask/utils.pyttakes_multiple_arguments4s    &  $tDispatchcB`sSeZdZddZddZddZdZdZe dZRS(sSimple single dispatch.cC`s(i|_i|_|r$||_ndS(N(t_lookupt_lazyRQ(RMtname((s)lib/python2.7/site-packages/dask/utils.pyRNes  c`s,fd}|dk r(||S|S(s7Register dispatch of `func` on arguments of type `type`c`sDttr3x.D]}j||qWn |j<|S(N(RRZtregisterR(RRU(RMR(s)lib/python2.7/site-packages/dask/utils.pytwrapperms   N(R(RMRRR((RMRs)lib/python2.7/site-packages/dask/utils.pyRksc`s,fd}|dk r(||S|S(s Register a registration function which will be called if the *toplevel* module (e.g. 'pandas') is ever loaded. c`s|j<|S(N(R(R(RMttoplevel(s)lib/python2.7/site-packages/dask/utils.pyR|s N(R(RMRRR((RMRs)lib/python2.7/site-packages/dask/utils.pyt register_lazywscC`s|j}y||}Wntk r*nX|S|jjd\}}}y|jj|}Wntk rsnX||j|Sx=tj|dD](}||kr||||<||SqWt dj |dS(s8Return the function implementation for the given ``cls``R'isNo dispatch for {0}N( RtKeyErrorRRt partitionRtpoptdispatchtinspecttgetmrot TypeErrortformat(RMtclstlktimplRt_Rtcls2((s)lib/python2.7/site-packages/dask/utils.pyRs$      cO`s%|jt|}||||S(sJ Call the corresponding method based on type of argument. (RR(RMtargRtkwargstmeth((s)lib/python2.7/site-packages/dask/utils.pyt__call__scC`s:y|jt}|jSWntk r5d|jSXdS(NsSingle Dispatch for %s(RtobjectRSRRQ(RMR((s)lib/python2.7/site-packages/dask/utils.pyRSs   N( RQRRRSRRNRRRRtproperty(((s)lib/python2.7/site-packages/dask/utils.pyRcs   cC`s@ytj|Wn(tk r;}|jtkr<q<nXdS(s, Ensure that a file does not exist. N(R,tunlinkR4terrnoR(R7te((s)lib/python2.7/site-packages/dask/utils.pytensure_not_existss cC`sj|j}|dks'|jdr+|Sd|krbd|krbd|krW|dS|dSn|SdS(Ns>>>s>>> #s+SKIPs # doctest:s, +SKIPs # doctest: +SKIP(tstript startswith(tlinetstripped((s)lib/python2.7/site-packages/dask/utils.pyt _skip_doctests   cC`s?|dkrdSdjg|jdD]}t|^q&S(NR&s (RtjointsplitR(tdocR((s)lib/python2.7/site-packages/dask/utils.pyt skip_doctests c`s|jdfdttdD}t}xt|jD]\}}||krd|}|j|||<|djdt|dt||ds(RzR(RtRo(tlines(s)lib/python2.7/site-packages/dask/utils.pys s isExtra R( RtrangeRctsettsortedRtreplacetaddR(RttitlestseenRottitlet new_title((Rs)lib/python2.7/site-packages/dask/utils.pyt extra_titless&   c C`sd|j|j|f}d}|jd}|dkr||d }||d}tjd|jd} |r| |jddg} ng} || || |dg| |g} d j| }n|S( s4Expand docstring by adding disclaimer and extra texts+This docstring was copied from %s.%s.%s. s5Some inconsistencies with the Dask version may exist.s iis\s*is R&(RRRQtfindtretmatchtgrouptrstripR( RRRtextratl1tl2Rotheadttailtindenttmoretbits((s)lib/python2.7/site-packages/dask/utils.pytignore_warnings #cC`s|jd}x|D]}}gt|D]2\}}tjd|d|r)||f^q)}t|dkr|\\}}|d||tddpd}tdd|_SWnLtk rjjddtjfd}|SXdS(NRSR&RRR'ic`sMdjj}dk r=d}||j7}nt|dS(Ns#Base package doesn't support '{0}'.s) Use {0} {1} or later to use this method.(RRQRtNotImplementedError(RRtmsgtmsg2(Rt module_nametversion(s)lib/python2.7/site-packages/dask/utils.pytwrappedAs  ( RRRRSR?RRRt functoolstwraps(RRR(toriginal_klassRR(RRs)lib/python2.7/site-packages/dask/utils.pyR6s $((RRRR((RRRs)lib/python2.7/site-packages/dask/utils.pyt derived_from$scC`st|tjrt|jSt|tr5|jSt|dd pJd}tt |dd phd}d|krd|kr|j Sd|krd|kr|j Sy!|j }|dkrd S|SWnt k rt|SXd S( sGet the name of a function.RRR&RQttoolztcurrytmultipledispatcht DispatcherstlambdaN(RRtpartialtfuncnameRt methodcallerRRRRt func_nameRRQR?tstr(RRt type_nameR((s)lib/python2.7/site-packages/dask/utils.pyRLs"    cC`s6|j s|jdkr |jS|jd|jSdS(s Return the name of a type Examples -------- >>> typename(int) 'int' >>> from dask.core import literal >>> typename(literal) 'dask.core.literal' tbuiltinsR'N(RRRQ(ttyp((s)lib/python2.7/site-packages/dask/utils.pyttypenameis cC`sFt|tr|St|dr,|jSd}t||dS(s Turn string or bytes to bytes >>> ensure_bytes(u'123') b'123' >>> ensure_bytes('123') b'123' >>> ensure_bytes(b'123') b'123' tencodes<Object %s is neither a bytes object nor has an encode methodN(RRxRsRR(tsR((s)lib/python2.7/site-packages/dask/utils.pyt ensure_bytes|s  cC`sFt|tr|St|dr,|jSd}t||dS(s Turn string or bytes to bytes >>> ensure_unicode(u'123') '123' >>> ensure_unicode('123') '123' >>> ensure_unicode(b'123') '123' tdecodes<Object %s is neither a bytes object nor has an encode methodN(RR RsRR(RR((s)lib/python2.7/site-packages/dask/utils.pytensure_unicodes  cC`s||||S(s >>> digit(1234, 0, 10) 4 >>> digit(1234, 1, 10) 3 >>> digit(1234, 2, 10) 2 >>> digit(1234, 3, 10) 1 ((Rtktbase((s)lib/python2.7/site-packages/dask/utils.pytdigits cC`s t|}|||>> insert(('a', 'b', 'c'), 0, 'x') ('x', 'b', 'c') (RRZ(ttuptloctvaltL((s)lib/python2.7/site-packages/dask/utils.pytinserts  c`sYddl}t|\}|jfdtfdjDS(Nic`s6|sdSdtfd|D}|S(Nic3`s|]}|VqdS(N((Rttdep_key(tmax_depth_by_deps(s)lib/python2.7/site-packages/dask/utils.pys s(tmax(RORW(tdepsR(s)lib/python2.7/site-packages/dask/utils.pyRs $c3`s|]}|VqdS(N((RtR(R(s)lib/python2.7/site-packages/dask/utils.pys s(RRtmemoizeRtkeys(tdskRR((R Rs)lib/python2.7/site-packages/dask/utils.pytdependency_depths cC`sHxAdddddgD]*}|dkr6d||fS|d}qWdS(NRxtKBtMBtGBtTBg@s%3.1f %s((tnumRm((s)lib/python2.7/site-packages/dask/utils.pyt memory_reprs c`sg|D]}td|D^q}td|D}tdtt||D}ddt||t|}ddjd|D}d jfd |D}d j|||||gS( sFormats an ascii table for given columns and rows. Parameters ---------- columns : list The column names rows : list of tuples The rows in the table. Each tuple must be the same length as ``columns``. cs`s|]}t|VqdS(N(R(RtRo((s)lib/python2.7/site-packages/dask/utils.pys scs`s|]}t|VqdS(N(R(RtRo((s)lib/python2.7/site-packages/dask/utils.pys scs`s9|]/\}}tttt|t|VqdS(N(RR[Rc(RtRmR((s)lib/python2.7/site-packages/dask/utils.pys st|s %%-%ds |s+%s+t+cs`s|]}d|dVqdS(RiN((RtR<((s)lib/python2.7/site-packages/dask/utils.pys ss c3`s|]}|VqdS(N((Rttr(t row_template(s)lib/python2.7/site-packages/dask/utils.pys s(RZRRcR(tcolumnstrowsRtwidthstheadertbartdata((Rs)lib/python2.7/site-packages/dask/utils.pyt asciitables ) cC`sRtd|Dr8g|D]}t|^q}n|jdj|dS(Ncs`s|]}t|t VqdS(N(RR (RtRm((s)lib/python2.7/site-packages/dask/utils.pys ss (tanyR R>R(tbufRRm((s)lib/python2.7/site-packages/dask/utils.pyt put_liness"RcB`sMeZdZdZedZdZdZdZdZ e Z RS(s Return a callable object that calls the given method on its operand. Unlike the builtin `operator.methodcaller`, instances of this class are serializable RcC`s|jS(N(R(RM((s)lib/python2.7/site-packages/dask/utils.pytR&cC`s:|tkrt|Stj|}||_|t|<|S(N(t _method_cacheRt__new__R(RRRM((s)lib/python2.7/site-packages/dask/utils.pyR$s    cO`st||j||S(N(RR(RMtobjRR((s)lib/python2.7/site-packages/dask/utils.pyRscC`st|jffS(N(RR(RM((s)lib/python2.7/site-packages/dask/utils.pyt __reduce__scC`sd|jj|jfS(Ns<%s: %s>(t __class__RQR(RM((s)lib/python2.7/site-packages/dask/utils.pyt__str__ s(R( RQRRRSRTRRR$RR&R(t__repr__(((s)lib/python2.7/site-packages/dask/utils.pyRs    t itemgettercB`s8eZdZdZdZdZdZdZRS(s Return a callable object that gets an item from the operand Unlike the builtin `operator.itemgetter`, instances of this class are serializable tindexcC`s ||_dS(N(R+(RMR+((s)lib/python2.7/site-packages/dask/utils.pyRNscC`s ||jS(N(R+(RMRm((s)lib/python2.7/site-packages/dask/utils.pyRscC`st|jffS(N(R*R+(RM((s)lib/python2.7/site-packages/dask/utils.pyR&scC`s(t|t|ko'|j|jkS(N(RR+(RMtother((s)lib/python2.7/site-packages/dask/utils.pyt__eq__!s(R+(RQRRRSRTRNRR&R-(((s)lib/python2.7/site-packages/dask/utils.pyR*s    t MethodCachecB`s#eZdZeeZdZRS(sAttribute access on this object returns a methodcaller for that attribute. Examples -------- >>> a = [1, 3, 3] >>> M.count(a, 3) == a.count(3) True cC`s ttS(N(RR#(RM((s)lib/python2.7/site-packages/dask/utils.pyR"0R&(RQRRRSt staticmethodRt __getattr__t__dir__(((s)lib/python2.7/site-packages/dask/utils.pyR.%s  tSerializableLockcB`skeZeZd dZdZdZdZdZ dZ dZ dZ dZ e ZRS( cC`sf|pttj|_|jtjkrCtj|j|_nt|_|jtj|j(R'RQR5(RM((s)lib/python2.7/site-packages/dask/utils.pyR(osN(RQRRRR6RRNR8R9R:R;R<R=R>R(R)(((s)lib/python2.7/site-packages/dask/utils.pyR26s          cC`sdddlm}ddlm}|d|gd|}||jkr]|jjjStS(s_Get an instance of the appropriate lock for a certain situation based on scheduler used.i(tmultiprocessing(t get_schedulert collectionst scheduler( R&R?RR@tgett get_contexttManagerRR2(t collectionRBR?R@t actual_get((s)lib/python2.7/site-packages/dask/utils.pytget_scheduler_lockus cC`s`t|tkr|St|drVi}x$|jjD]}|j|q;W|St|S(Ntdicts(RtdictRsRItvaluestupdate(RWtresulttdd((s)lib/python2.7/site-packages/dask/utils.pyt ensure_dictstOperatorMethodMixincB`s>eZdZedZedZeedZRS(s.A mixin for dynamically implementing operatorscC`s|j}|jdr%|d }n|dkr:d}ndj|}|dkrqt|||j|nWt|||j||dkrdSdj|}t|||j|dtdS(s bind operator to this class Ritinvtinverts__{0}__tabstnegtposteqtgttgetlttletnetgetitemNs__r{0}__(RSRRRTRU(RVRWRXRYRZR[R\(RQtendswithRR t_get_unary_operatort_get_binary_operatorR(RtopRRtrmeth((s)lib/python2.7/site-packages/dask/utils.pyt_bind_operators      cC`s tdS(s- Must return a method used by unary operator N(R(RR`((s)lib/python2.7/site-packages/dask/utils.pyR^scC`s tdS(s. Must return a method used by binary operator N(R(RR`RQ((s)lib/python2.7/site-packages/dask/utils.pyR_s(RQRRRSt classmethodRbR^RR_(((s)lib/python2.7/site-packages/dask/utils.pyRPs cO`s^|jd}|jd}t|}x$|D]\}}|j||q1W|||S(si >>> from operator import add >>> partial_by_order(5, function=add, other=[(1, 10)]) 15 tfunctionR,(RRR(RRRdR,targs2RoR((s)lib/python2.7/site-packages/dask/utils.pytpartial_by_orders  c`sUddlmt|doT|joTt|doTtfd|jD S(s Is this object a numpy array or something similar? Examples -------- >>> import numpy as np >>> x = np.ones(5) >>> is_arraylike(x) True >>> is_arraylike(5) False >>> is_arraylike('cat') False i(tis_dask_collectiontshapeR]c3`s|]}|VqdS(N((RtR(Rg(s)lib/python2.7/site-packages/dask/utils.pys s(RRgRsRhR(Rm((Rgs)lib/python2.7/site-packages/dask/utils.pyt is_arraylikescC`s;gtjd|D]$}|jr1t|n|^qS(s Sorting `key` function for performing a natural sort on a collection of strings See https://en.wikipedia.org/wiki/Natural_sort_order Parameters ---------- s : str A string that is an element of the collection being sorted Returns ------- tuple[str or int] Tuple of the parts of the input string where each part is either a string or an integer Examples -------- >>> a = ['f0', 'f1', 'f2', 'f8', 'f9', 'f10', 'f11', 'f19', 'f20', 'f21'] >>> sorted(a) ['f0', 'f1', 'f10', 'f11', 'f19', 'f2', 'f20', 'f21', 'f8', 'f9'] >>> sorted(a, key=natural_sort_key) ['f0', 'f1', 'f2', 'f8', 'f9', 'f10', 'f11', 'f19', 'f20', 'f21'] s(\d+)(RRtisdigittint(Rtpart((s)lib/python2.7/site-packages/dask/utils.pytnatural_sort_keysc`sKfdtdttddD}ttjtj|S(sV Return the factors of an integer https://stackoverflow.com/a/6800214/616616 c3`s/|]%}|dkr||gVqdS(iN((RtRo(R(s)lib/python2.7/site-packages/dask/utils.pys sig?(RRktpowRRtreduceRt__add__(RR((Rs)lib/python2.7/site-packages/dask/utils.pytfactorss2cC`s|jdd}|djs/d|}nx8tt|dddD]}||jsLPqLqLW|d}|| }||}yt|}Wn!tk rtd|nXyt|j}Wn!t k rtd|nX||}t |S( s Parse byte string to numbers >>> parse_bytes('100') 100 >>> parse_bytes('100 MB') 100000000 >>> parse_bytes('100M') 100000000 >>> parse_bytes('5kB') 5000 >>> parse_bytes('5.4 kB') 5400 >>> parse_bytes('1kiB') 1024 >>> parse_bytes('1e6') 1000000 >>> parse_bytes('1e6 kB') 1000000000 >>> parse_bytes('MB') 1000000 >>> parse_bytes('5 foos') # doctest: +SKIP ValueError: Could not interpret 'foos' as a byte unit t R&it1iis$Could not interpret '%s' as a numbers'Could not interpret '%s' as a byte unit( RRjRRctisalphaRRt byte_sizestlowerRRk(RRoR+tprefixtsuffixRt multiplierRM((s)lib/python2.7/site-packages/dask/utils.pyt parse_bytess& #      i itkBiRi Ri RitPBitKiBitMiBitGiBi(tTiBi2tPiBtBcC`s%i|]\}}||jqS((Rv(RtRtv((s)lib/python2.7/site-packages/dask/utils.pys As cC`s5i|]+\}}|rd|kr||dqS(Roi((RtRR((s)lib/python2.7/site-packages/dask/utils.pys Bs cC`s5i|]+\}}|rd|kr||d qS(Roi((RtRR((s)lib/python2.7/site-packages/dask/utils.pys Cs cC`szyatr|tj|jkSt|tjrJ|tj|jj kS|tj|j kSWnt k rut SXdS(N( R Rt signaturet parametersRRRR RRRR(Rtkeyword((s)lib/python2.7/site-packages/dask/utils.pyt has_keywordFs cC`s9t|ttfsdS|s#dSdt|dSdS(Nii(RRRZtndimlist(R((s)lib/python2.7/site-packages/dask/utils.pyRSs ii@Biʚ;IIƤ~iii@II(t __future__RRRRRR,R2tsysR*RRRt contextlibRt importlibRtnumbersRt threadingRR3tweakrefRt compatibilityR R R R R RtcoreRt optimizationRtgetdefaultencodingtsystem_encodingRRRR R%RR8R;RARCRHRIRJRRKRRYR\RrRRRRSRzRtboolt bytearrayRxtcallabletchrRctcomplexRJR(RhtevalRRt frozensetthashthextidRktiterRcRRtmintnexttocttordRtreprtreversedtroundtsliceRR/RtsumRZRtvarsRt memoryviewRRRtcompiletdelattrtdivmodtfilterRRsRt issubclassR[RntsetattrRRRRRRRRRRRRRRRRRR RRR!R#RR*R.tMR2RHRORPRfRiRmRqRzRuRRLRR(((s)lib/python2.7/site-packages/dask/utils.pyts        .       !      /I     !(          ? &    2