\c@`s ddlmZmZmZddlZddlmZddlmZddl m Z ddl Z ddl m Z ddlZddlZddlZddlZddlmZddlZddlZddlZddlZddlZddlmZdd lmZddlZddlZddlZddl Z ddl!Z!ddl"Z"ddl#Z$d d l%m&Z&m'Z'm(Z(m)Z)yddl*Z*Wne+k rdZ*nXddl-Z-dd l-m.Z.ddl/Z/ddl0Z0dd l0m1Z1ddl2m3Z3yddl2m4Z4Wne+k r1dZ4nXd dl%m5Z5m6Z6m7Z7m8Z8m9Z9d dl:mZyddl;m<Z<Wne+k rej=Z<nXej>e?Z@ZAdZBdZCeCZDdZEdZFdZGe/jHdZIdddZJdddZKdZLedZMe1jNd ZOe1jNdd!ZPe1jNdd"ZQd#ZRd$eSfd%YZTed&ZUed'ZVd(ZWd)ZXejYd*ZZd+Z[ydd,l m\Z\Wne+k re]Z\nXe\d-e[Z[e6r!d.Z^n d/Z^ee]d0Z_d1d2Z`e/jHd3Zae$jbjcd4Zdd5d6Zeejfdkrd8dUn d9Zgd:Zhdd;Zid<Zjd=Zkd>Zld?Zmdd@ZndAZoddBZpedCdDZqdEZrdFZsdGZteuedHrGejvdIZwn.e]gZxexdJZyexdKZwejzeydLew_{dCdMZ|dNZ}dOeSfdPYZ~dQZi ddS6ddU6ddW6ddY6dd[6dd]6dd_6dda6ddc6dde6d df6d dC6ZdgejDZejdhejDejdiejDdjZid dk6dldm6dndo6dpdq6drds6dtdu6ddw6Zid dx6drdy6ddz6dd{6dld|6dnd}6dpd~6ZejdejDejeejdejDddZdZe7rMeeefdZneefdZddZedZejdZdZdejfdYZdZdejkrte0jfddkrte]Zdejkr7ddlZddlmZejjjo1eejjjeZnestddlZddlZ0eje0jjjqtndZe\re\deZnddddddddddddddddddgZe/jHedZdZedZdZdS(i(tprint_functiontdivisiontabsolute_importN(tdeque(tcontextmanager(t timedelta(tmd5(tNumber(tsleep(t import_modulei(tcache_from_sourcet getargspectinvalidate_cachestreload(tistask(tgen(tIOLoop(t PollIOLoop(tQueuetPY3tPY2tget_thread_identitytunicode(ttime(t thread_statet__no_default__cC`strtjjd rdtjkrtjjd}tj |}dg}dtj krq|j dn|j |nt}|S(NtwintPyPys)distributed.worker.multiprocessing-methodt distributedt pkg_resources( Rtsystplatformt startswithtversiontdasktconfigtgettmultiprocessingt get_contexttmodulestappendtset_forkserver_preload(tmethodtctxtpreload((s0lib/python2.7/site-packages/distributed/utils.pyt_initialize_mp_context@s( cC`sIxt|dr|j}qWy |jSWntk rDt|SXdS(sGet the name of a function.tfuncN(thasattrR.t__name__tAttributeErrortstr(R.((s0lib/python2.7/site-packages/distributed/utils.pytfuncnameRs    cC`sex^tr`y|t|jkr%tSWntk r:PnXy |j}Wqtk r\PqXqWtS(sE Whether the function takes an argument with the given name. (tTrueR targst TypeErrort __wrapped__R1tFalse(R.targname((s0lib/python2.7/site-packages/distributed/utils.pythas_arg\s     cC`s(tdk r tjtjdSdSdS(s; Get the maximum number of open files per process. iiN(tresourcetNonet getrlimitt RLIMIT_NOFILE(((s0lib/python2.7/site-packages/distributed/utils.pytget_fileno_limitns cC`stj|tj}zcy+|j||f|jd}|SWn1tk rv}tjd|||ft|SXWd|jXdS(NisKCouldn't detect a suitable IP address for reaching %r, defaulting to %r: %s( tsockett SOCK_DGRAMtconnectt getsocknametEnvironmentErrortwarningstwarntRuntimeWarningtclose(thosttporttfamilytdefaulttsocktipte((s0lib/python2.7/site-packages/distributed/utils.pyt_get_ipzs  s8.8.8.8iPcC`st||dtjddS(s Get the local IP address through which the *host* is reachable. *host* defaults to a well-known Internet host (one of Google's public DNS servers). RKRLs 127.0.0.1(RPR@tAF_INET(RIRJ((s0lib/python2.7/site-packages/distributed/utils.pytget_ipss2001:4860:4860::8888cC`st||dtjddS(s- The same as get_ip(), but for IPv6. RKRLs::1(RPR@tAF_INET6(RIRJ((s0lib/python2.7/site-packages/distributed/utils.pytget_ipv6scC`sWddl}x1|j|D]}|jtjkr|jSqWtd|fdS(s Get the local IPv4 address of a network interface. KeyError is raised if the interface doesn't exist. ValueError is raised if the interface does no have an IPv4 address associated with it. iNs)interface %r doesn't have an IPv4 address(tpsutilt net_if_addrsRKR@RQtaddresst ValueError(tifnameRUtinfo((s0lib/python2.7/site-packages/distributed/utils.pytget_ip_interfaces   cg`s#y dVWn|k r}nXdS(N((t exceptionsRO((s0lib/python2.7/site-packages/distributed/utils.pytignorings cg`shtj|}g}x=|jsTt||jV}|j|WdQXqWtj|dS(s Process list of coroutines, ignoring certain exceptions >>> coroutines = [cor(...) for ...] # doctest: +SKIP >>> x = yield ignore_exceptions(coroutines, TypeError) # doctest: +SKIP N(Rt WaitIteratortdoneR]tnextR(tReturn(t coroutinesR\t wait_iteratortresultstresult((s0lib/python2.7/site-packages/distributed/utils.pytignore_exceptionss  c#`stj|g|D] }d^q}xgjsyjV}Wn6tk rtjfd}|nX||j!              i cC`s!|j|j|WdQXdS(sv Stop and close the loop if it was created by us. Otherwise, just mark this object "stopped". N(Rt_stop_unlocked(RR((s0lib/python2.7/site-packages/distributed/utils.pytstops cC`s|js dSt|_|j|j\}}|dkrU|d|f|j|j>> is_kernel() False tIPythoni(t get_ipythontkernelN(RR'R8RRRR<(R((s0lib/python2.7/site-packages/distributed/utils.pyt is_kernelss[a-f]+cC`smt|tkr!|j}nt|tkr@|d}ny|jd}|ddjs|djddjd}n |d}xX|dD]L}|jrt|dkotj |dk r|d|7}qPqWt|dkrt j d|rd S|dd krO|jd jdjd d }n|SWnt k rhdSXdS(s5 >>> key_split('x') 'x' >>> key_split('x-1') 'x' >>> key_split('x-1-2-3') 'x' >>> key_split(('x-2', 1)) 'x' >>> key_split("('x-2', 1)") 'x' >>> key_split("('x', 1)") 'x' >>> key_split('hello-world-1') 'hello-world' >>> key_split(b'hello-world-1') 'hello-world' >>> key_split('ae05086432ca935f6eba409a8ecd4896') 'data' >>> key_split('>> key_split(None) 'Other' >>> key_split('x-abcdefab') # ignores hex 'x' it-t,s'("iii s [a-f0-9]{32}tdatatt.itOtherN( ttypetbytestdecodettupletsplittisalphatstriptlent hex_patterntmatchR<treRm(tstwordsRetword((s0lib/python2.7/site-packages/distributed/utils.pyt key_split,s* #  ($) (t lru_cacheicC`st|}|tkr |dS|tkr|ddkrY|jdddjdSt|dkrtjd|rdS|dd kr|jd jdjd d S|Sn |tkrt |j Sd SdS(sA more fine-grained version of key_split >>> key_split_group('x') 'x' >>> key_split_group('x-1') 'x-1' >>> key_split_group('x-1-2-3') 'x-1-2-3' >>> key_split_group(('x-2', 1)) 'x-2' >>> key_split_group("('x-2', 1)") 'x-2' >>> key_split_group('hello-world-1') 'hello-world-1' >>> key_split_group(b'hello-world-1') 'hello-world-1' >>> key_split_group('ae05086432ca935f6eba409a8ecd4896') 'data' >>> key_split_group('>> key_split_group(None) 'Other' >>> key_split_group('x-abcdefab') # ignores hex 'x-abcdefab' it(Ris()"'i s [a-f0-9]{32}RRs<>RiRN( RRR2RRRRRRtkey_split_groupR(txttyp((s0lib/python2.7/site-packages/distributed/utils.pyRls   $$ cC`st|}|tkr |dS|tks8|tkr|ddkre|jdddjdSt|dkrtjd|rdS|dd kr|jd jdjd d S|Snd SdS(sA more fine-grained version of key_split >>> key_split_group('x') 'x' >>> key_split_group('x-1') 'x-1' >>> key_split_group('x-1-2-3') 'x-1-2-3' >>> key_split_group(('x-2', 1)) 'x-2' >>> key_split_group("('x-2', 1)") 'x-2' >>> key_split_group('hello-world-1') 'hello-world-1' >>> key_split_group(b'hello-world-1') 'hello-world-1' >>> key_split_group('ae05086432ca935f6eba409a8ecd4896') 'data' >>> key_split_group('>> key_split_group(None) 'Other' >>> key_split_group('x-abcdefab') # ignores hex 'x-abcdefab' iRRis()"'i s [a-f0-9]{32}RRs<>RiRN( RRR2RRRRRR(RR((s0lib/python2.7/site-packages/distributed/utils.pyRs  $$cc`sddlm}y dVWnv|tjfk r8nZtk r}ytj|Wntk rknX|rddl}|j nnXdS(Ni(tCommClosedErrori( tcommRRRaRmtloggert exceptionR6tpdbt set_trace(RRRO((s0lib/python2.7/site-packages/distributed/utils.pyt log_errorss    RcC`st|tr'tt|j}nd}tj|}x<|jD]1}t|tjrF|j }|j |qFqFW|S(sK Change all StreamHandlers for the given logger to the given level N( RR2RtloggingtupperR<t getLoggerthandlerst StreamHandlertleveltsetLevel(RtrootRRthandler((s0lib/python2.7/site-packages/distributed/utils.pytsilence_loggings cC`s{tjtjg}x\|D]T}ytj|d|tj}Wntjk r\}|}qX|dddSqW|dS(s Ensure that address is an IP address Examples -------- >>> ensure_ip('localhost') '127.0.0.1' >>> ensure_ip('123.123.123.123') # pass through IP addresses '123.123.123.123' iiiN(R@RQRSt getaddrinfot SOCK_STREAMtgaierror(thostnametfamiliestfamRdROR~((s0lib/python2.7/site-packages/distributed/utils.pyt ensure_ips   c`stj\}}tjjddtjjddtjjddtjjddg}x/rtfd|DrjqfWS( NRtworkert schedulerttornadosgen.pyt concurrenttfuturesc3`s$|]}|jjjkVqdS(N(ttb_frametf_codet co_filename(t.0tb(t exc_traceback(s0lib/python2.7/site-packages/distributed/utils.pys s(RR{RRRtanyttb_next(texc_typet exc_valuetbad((Rs0lib/python2.7/site-packages/distributed/utils.pyt get_tracebacks  i'cC`sutt||krmy!t|dt|| SWqqtk ritdt|t|| SXn|SdS(s1 Truncate exception to be about a certain length sLong error messageN(RR2RRm(ROtn((s0lib/python2.7/site-packages/distributed/utils.pyttruncate_exceptions ! $isdef queue_to_iterator(q): while True: result = q.get() if isinstance(result, StopIteration): return result.value yield result cc`s:x3tr5|j}t|tr-|n|VqWdS(N(R4R$Rt StopIteration(RRe((s0lib/python2.7/site-packages/distributed/utils.pytqueue_to_iterator-s    cC`s"x|D]}|j|qWdS(N(tput(tseqRtitem((s0lib/python2.7/site-packages/distributed/utils.pyt_dump_to_queue5s cC`sDtd|}tjdtd||f}t|_|j|S(NtmaxsizeRR5(RRRR$R4RR(R"R%Rtt((s0lib/python2.7/site-packages/distributed/utils.pytiterator_to_queue:s   cC`s6t|}|tks$|tkr(|St|SdS(s Convert an object to a string. Examples -------- >>> tokey(b'x') 'x' >>> tokey('x') 'x' >>> tokey(1) '1' N(RRRR2(toR((s0lib/python2.7/site-packages/distributed/utils.pyttokeyDs cC`sAt|}|tk r=|tk r=td||fndS(s,Validate a key as received on a stream. s"Unexpected key type %s (value: %r)N(RRRR6(RR((s0lib/python2.7/site-packages/distributed/utils.pyt validate_keyXs cC`s^t|p]t|tkr3ttt|p]t|tko]ttt|jS(s! Possibly contains a nested task (RRRgRtmapt_maybe_complextdicttvalues(Ri((s0lib/python2.7/site-packages/distributed/utils.pyR,`s  c`st|tkr5g|D]}t|^qSt|tkrdfd|jDSt|r|dftfd|dDSy&|ks|krt|SWntk rnX|S(Nc`s+i|]!\}}t||qS((tconvert(RRR(tdskt extra_values(s0lib/python2.7/site-packages/distributed/utils.pys os ic3`s!|]}t|VqdS(N(R/(RR(R0R1(s0lib/python2.7/site-packages/distributed/utils.pys qsi( RRgR/R-RRRR)R6(RiR0R1R((R0R1s0lib/python2.7/site-packages/distributed/utils.pyR/ks# , c`sfdjDS(Nc`s1i|]'\}}t|t|qS((R/R)(RRR(R0R1(s0lib/python2.7/site-packages/distributed/utils.pys {s (R(R0R1((R0R1s0lib/python2.7/site-packages/distributed/utils.pyt str_graphzscC`s|jdkrdSd}xtr|j|}|s>dS||}yB|j|}|j|jt||t|dSWntk rnX|t| }qWdS(s Seek current file to next byte after a delimiter bytestring This seeks the file to the next byte following the delimiter. It does not return anything. Use ``file.tell()`` to see location afterwards. Parameters ---------- file: a file delimiter: bytes a delimiter like ``b' '`` or message sentinel blocksize: int Number of bytes to read from the file at once. iNt(ttellR4treadtindextseekRRX(tfilet delimitert blocksizetlastRtfullti((s0lib/python2.7/site-packages/distributed/utils.pytseek_delimiter~s  + cC`s|r}|j|t||d|j}|||8}|j||t||d|j}|}||}n|j||j|}|S(s% Read a block of bytes from a file Parameters ---------- f: file File-like object supporting seek, read, tell, etc.. offset: int Byte offset to start read length: int Number of bytes to read delimiter: bytes (optional) Ensure reading starts and stops at delimiter bytestring If using the ``delimiter=`` keyword argument we ensure that the read starts and stops at delimiter boundaries that follow the locations ``offset`` and ``offset + length``. If ``offset`` is zero then we start at zero. The bytestring returned WILL include the terminating delimiter string. Examples -------- >>> from io import BytesIO # doctest: +SKIP >>> f = BytesIO(b'Alice, 100\nBob, 200\nCharlie, 300') # doctest: +SKIP >>> read_block(f, 0, 13) # doctest: +SKIP b'Alice, 100\nBo' >>> read_block(f, 0, 13, delimiter=b'\n') # doctest: +SKIP b'Alice, 100\nBob, 200\n' >>> read_block(f, 10, 10, delimiter=b'\n') # doctest: +SKIP b'Bob, 200\nCharlie, 300' iiii(R7R>R4R5(RtoffsettlengthR9RtendR((s0lib/python2.7/site-packages/distributed/utils.pyt read_blocks"     R3cc`sd|jd}tj|\}}tj|tj||Vtjj|rtjj|r{t j |qytj|Wqt k rqXndS(NR( tlstripRtmkstempRRHRRRtisdirtshutiltrmtreetOSError(t extensionthandleR((s0lib/python2.7/site-packages/distributed/utils.pyttmpfiles   cC`st|tr|St|tr,|jSt|tsPtrZt|trZt|St|drs|jSt d|dS(ss Turn string or bytes to bytes >>> ensure_bytes('123') b'123' >>> ensure_bytes(b'123') b'123' tencodes<Object %s is neither a bytes object nor has an encode methodN( RRt memoryviewttobytest bytearrayRtbufferR/RLR6(R((s0lib/python2.7/site-packages/distributed/utils.pyt ensure_bytess $  cC`sgt|}d}g}xH|D]@}||||}t|d\}}|jt|qW|S(s >>> divide_n_among_bins(12, [1, 1]) [6, 6] >>> divide_n_among_bins(12, [1, 2]) [4, 8] >>> divide_n_among_bins(12, [1, 2, 1]) [3, 6, 3] >>> divide_n_among_bins(11, [1, 2, 1]) [2, 6, 3] >>> divide_n_among_bins(11, [.1, .2, .1]) [2, 6, 3] gi(tsumtdivmodR(tint(RtbinsttotaltacctoutRtnow((s0lib/python2.7/site-packages/distributed/utils.pytdivide_n_among_binss  cC`s t|}t|t|S(N(RgRRR(R"((s0lib/python2.7/site-packages/distributed/utils.pytmeans t is_finalizingcC`s|S(N((R\((s0lib/python2.7/site-packages/distributed/utils.pyt shutting_downscC`st|d>> data = [0, 1, 2] >>> get_1 = itemgetter(1) >>> get_1(data) 1 R6cC`s ||_dS(N(R6(RR6((s0lib/python2.7/site-packages/distributed/utils.pyRxscC`s ||jS(N(R6(RR((s0lib/python2.7/site-packages/distributed/utils.pyt__call__{scC`st|jffS(N(RqR6(R((s0lib/python2.7/site-packages/distributed/utils.pyt __reduce__~s(R6(R0RRt __slots__RRrRs(((s0lib/python2.7/site-packages/distributed/utils.pyRqks    cC`s|dkrd|dS|dkr0d|dS|dkrHd|dS|dkr`d|dS|d krxd |d Sd |S( s* Format bytes as text >>> format_bytes(1) '1 B' >>> format_bytes(1234) '1.23 kB' >>> format_bytes(12345678) '12.35 MB' >>> format_bytes(1234567890) '1.23 GB' >>> format_bytes(1234567890000) '1.23 TB' >>> format_bytes(1234567890000000) '1.23 PB' g4&k Cs%0.2f PBgmBs%0.2f TBgeAs%0.2f GBg.As%0.2f MBg@@s%0.2f kBis%d B((R((s0lib/python2.7/site-packages/distributed/utils.pyt format_bytess          i tkBitMBi tGBi tTBitPBitKiBitMiBitGiBi(tTiBi2tPiBtBcC`s%i|]\}}||jqS((tlower(RRR((s0lib/python2.7/site-packages/distributed/utils.pys s cC`s5i|]+\}}|rd|kr||dqS(R=i((RRR((s0lib/python2.7/site-packages/distributed/utils.pys s cC`s5i|]+\}}|rd|kr||d qS(R=i((RRR((s0lib/python2.7/site-packages/distributed/utils.pys s cC`s|jdd}|djs/d|}nx8tt|dddD]}||jsLPqLqLW|d}|| }||}t|}t|j}||}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 t R3it1ii( treplacetisdigittrangeRRtfloatt byte_sizesRRT(RR=R6tprefixtsuffixRt multiplierRe((s0lib/python2.7/site-packages/distributed/utils.pyt parse_bytess #     RgMbP?tmsgư>tusg& .>tnsi<tmithitdtsecondtminutethourtdayt millisecondt microsecondt nanosecondcC`s#i|]\}}||dqS(R((RRR((s0lib/python2.7/site-packages/distributed/utils.pys s cC`s%i|]\}}||jqS((R(RRR((s0lib/python2.7/site-packages/distributed/utils.pys s Rvc C`st|tr|jSt|tr7t|}n|jdd}|djsfd|}nx8tt|dddD]}||j sPqqW|d}|| }||p|}t |}t |j }||}t ||kr t |}n|S(s Parse timedelta string to number of seconds Examples -------- >>> parse_timedelta('3s') 3 >>> parse_timedelta('3.5 seconds') 3.5 >>> parse_timedelta('300ms') 0.3 >>> parse_timedelta(timedelta(seconds=3)) # also supports timedeltas 3 RR3iRii(RRt total_secondsRR2RRRRRRttimedelta_sizesRRT( RRLR=R6RRRRRe((s0lib/python2.7/site-packages/distributed/utils.pytparse_timedeltas&  #    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(R2(RR=((s0lib/python2.7/site-packages/distributed/utils.pys 'scs`s|]}t|VqdS(N(R2(RR=((s0lib/python2.7/site-packages/distributed/utils.pys (scs`s9|]/\}}tttt|t|VqdS(N(tmaxR+R(RRtc((s0lib/python2.7/site-packages/distributed/utils.pys )st|s %%-%ds |s+%s+t+cs`s|]}d|dVqdS(RiN((RR((s0lib/python2.7/site-packages/distributed/utils.pys ,ss c3`s|]}|VqdS(N((Rtr(t row_template(s0lib/python2.7/site-packages/distributed/utils.pys -s(RtzipRR(tcolumnstrowsRtwidthstheadertbarR((Rs0lib/python2.7/site-packages/distributed/utils.pyt asciitables )%cC`sht||rt|St|tr]|jdkr>|jStjtj |j|jSn|j SdS(s* Number of bytes of a frame or memoryview N( RRRMtshapeR<titemsizet functoolstreducetoperatortmultnbytes(tframet _bytes_like((s0lib/python2.7/site-packages/distributed/utils.pyR3s cC`sCt||rt|Sy |jSWntk r>t|SXdS(s* Number of bytes of a frame or memoryview N(RRRR1(RR((s0lib/python2.7/site-packages/distributed/utils.pyRBs    cC`s<tjdkr"tjj||Stjj|||SdS(s Wrapper around tornado.IOLoop.PeriodicCallback, for compatibility with removal of the `io_loop` parameter in Tornado 5.0. iN(i(Rt version_infotiolooptPeriodicCallback(tcallbackt callback_timetio_loop((s0lib/python2.7/site-packages/distributed/utils.pyRMscc`sBt}dVt}|||kr>td|||ndS(Ns TIME WARNING(Rtprint(tdurationRRRA((s0lib/python2.7/site-packages/distributed/utils.pyt time_warnXs   cC`sx tjj|s"tdqWxgtdD]Y}y/t|}||}WdQX|rd|SWnttfk r~nXtdq0WdS(sB Reads a JSON file from disk that may be being written as we read g{Gz?i Ng?(RRRRRRRXR(RtloadR=Rtcfg((s0lib/python2.7/site-packages/distributed/utils.pytjson_load_robustascC`s8|dkrd|S|dkr,d|dSd|dS(s format integers as time >>> format_time(1) '1.00 s' >>> format_time(0.001234) '1.23 ms' >>> format_time(0.00012345) '123.45 us' >>> format_time(123.456) '123.46 s' is%.2f sgMbP?s%.2f msg@@s%.2f usg.A((R((s0lib/python2.7/site-packages/distributed/utils.pyt format_timeps   t DequeHandlercB`sDeZdZejZdZdZdZe dZ RS(s5 A logging.Handler that records records into a deque cO`sQ|jdd}td||_tt|j|||jj|dS(NRi'tmaxlen(RRtsuperRRt _instancestadd(RR5RR((s0lib/python2.7/site-packages/distributed/utils.pyRscC`s|jj|dS(N(RR((Rtrecord((s0lib/python2.7/site-packages/distributed/utils.pytemitscC`s|jjdS(s) Clear internal storage. N(Rtclear(R((s0lib/python2.7/site-packages/distributed/utils.pyRscC`s(x!t|jD]}|jqWdS(sG Clear the internal storage of all live DequeHandlers. N(RgRR(tclstinst((s0lib/python2.7/site-packages/distributed/utils.pytclear_all_instancess( R0RRRtWeakSetRRRRt classmethodR(((s0lib/python2.7/site-packages/distributed/utils.pyRs     cC`sKxDtjjjjD]-}x$tj|jD]}|jq/WqWdS(so Python 2's logger's locks don't survive a fork event https://github.com/dask/distributed/issues/1491 N(RtLoggertmanagert loggerDicttkeysRRt createLock(RR((s0lib/python2.7/site-packages/distributed/utils.pytreset_logger_locksstasyncioitnotebook(t NotebookAppcC`sQtr|tj|jkStj|r7|j}n|tj|jkSdS(N( Rtinspectt signaturet parametersRtis_coroutine_functionR7R R5(R.tkeyword((s0lib/python2.7/site-packages/distributed/utils.pyt has_keywords  is#440154s#471669s#472A79s#433C84s#3C4D8As#355D8Cs#2E6C8Es#287A8Es#23898Ds#1E978As#20A585s#2EB27Cs#45BF6Fs#64CB5Ds#88D547s#AFDC2Es#D7E219s#FDE724cC`sCtt|j}t|jd d}||t|S(Nii(RR2RLRTt hexdigestR(RtpaletteRR((s0lib/python2.7/site-packages/distributed/utils.pytcolor_ofscC`s9tj|rtStjdkr5tj|r5tStS(Nii(ii(RRR4RRRtiscoroutinefunctionR8(R((s0lib/python2.7/site-packages/distributed/utils.pyRs cc`sGt}dVt}||t|krCtj|ddndS(Nt stackleveli(RRRERF(RtmsgRR((s0lib/python2.7/site-packages/distributed/utils.pytwarn_on_durations   cC`s5y|jd|jSWntk r0t|SXdS(s Return name of type Examples -------- >>> from distributed import Scheduler >>> typename(Scheduler) 'distributed.scheduler.Scheduler' RN(RR0R1R2(R((s0lib/python2.7/site-packages/distributed/utils.pyttypenames  (((i(ii@Biʚ;IIƤ~iii@IIiQiiiQ(t __future__RRRtatexitt collectionsRt contextlibRtdatetimeRRthashlibRRtjsonRR%tnumbersRRRRRFR@RRt importlibR RRRRERRttblib.pickling_supportttblibt compatibilityR R R R R;t ImportErrorR<R"RttoolzRRttornado.ioloopRRRRRRRtmetricst dask.contextRtlocalRR0Rt_loggert no_defaultR-t mp_contextR3R:R?tmemoizeRPRRRTR[R]RnRfRqRrRtobjectRRRRRtcompileRRRR8RRRR tpickling_supporttinstallRRRR R$R'R)R*R,R/R2R>RBRKRQRZR[R/R\R]t_shutting_downR_tregisterRRbRpRqRuRRtupdateRRttds2RRRRORPRRRRRRtHandlerRRR'tjupyter_event_loop_initializedt traitletstnotebook.notebookappRR#t Applicationt initializedRtinstanceRttornado.platform.asynciotset_event_loop_policyRtAnyThreadEventLoopPolicyRRRRRR(((s0lib/python2.7/site-packages/distributed/utils.pyts                  "       (       )( 5   6  . *            ! 4          ,   *    (     "