ó O'—^c@@s2dZddlmZmZddlZddlZddlZddlZddlm Z ddl m Z m Z ddl mZddlmZddlmZmZydd lmZWnek rÕdZnXdd lmZmZmZd d lmZmZyddlZWn dZnXy#dd l m!Z!e"e#e!fZ$Wnek rje"e#fZ$nXdddddddddddddddgZ%iddddd„Z&de'fd „ƒYZ(d!„Z)de*fd"„ƒYZ+d#„Z,er er d$„Znd%„ZeZ-ej.dAkr6d)„Z/n d*„Z/d+„Z0d,dd,e1d-„Z2d,dd,d.d/„Z3giddd&d&d0dd1„Z4e5dd2„Z6de7fd3„ƒYZ8d4d5d6„Z9dBid4d7„Z:e d8„ƒZ;d9„Z<d:„Z=d;e7fd<„ƒYZ>d=d>„Z?d?„Z@d@„ZAdS(Cs/ kombu.utils =========== Internal utilities. i(tabsolute_importtprint_functionN(tcontextmanager(tcounttrepeat(twraps(tsleep(tUUIDtuuid4(t_uuid_generate_random(titemstreraisetstring_ti(tdefault_encodet safe_repr(tUnsupportedOperationt EqualityDicttsaytuuidtkwdictt maybe_listtfxranget fxrangemaxtretry_over_timetemergency_dump_statetcached_propertyt reprkwargstreprcalltnestedtfilenot maybe_filenot.c K@s8|dkrtj}nt|tƒs+|S|j|ƒp=|}d|krRdn|}|j|ƒ\}}} |s’d|r…|n| } }nyvy||d||} Wn?tk rï} tttdj || ƒƒt j ƒdƒnX| rt | | ƒS| SWn)t tfk r3|dkr4‚q4nX|S(s¸Get symbol by qualified name. The name should be the full dot-separated path to the class:: modulename.ClassName Example:: celery.concurrency.processes.TaskPool ^- class name or using ':' to separate module and symbol:: celery.concurrency.processes:TaskPool If `aliases` is provided, a dict containing short name/long name mappings, the name is looked up in the aliases first. Examples: >>> symbol_by_name('celery.concurrency.processes.TaskPool') >>> symbol_by_name('default', { ... 'default': 'celery.concurrency.processes.TaskPool'}) # Does not try to look up non-string names. >>> from celery.concurrency.processes import TaskPool >>> symbol_by_name(TaskPool) is TaskPool True t:tpackagesCouldn't import {0!r}: {1}iN(tNonet importlibt import_modulet isinstanceR tgett rpartitiont ValueErrorR tformattsystexc_infotgetattrt ImportErrortAttributeError( tnametaliasestimpR!tseptdefaulttkwargst module_namet_tcls_nametmoduletexc((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pytsymbol_by_name0s*#    t HashedSeqcB@s&eZdZdZd„Zd„ZRS(sOtype used for hash() to make sure the hash is not generated multiple times.t hashvaluecG@s||(t|ƒ|_dS(N(thashR<(tselftseq((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyt__init__qscC@s|jS(N(R<(R>((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyt__hash__us(t__name__t __module__t__doc__t __slots__R@RA(((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyR;ls cC@s-y|jƒSWntk r(t|ƒSXdS(N(t __eqhash__R.R=(to((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyteqhashys cB@s#eZd„Zd„Zd„ZRS(cC@s5t|ƒ}||kr%|j|ƒStj||ƒS(N(RHt __missing__tdictt __getitem__(R>tkeyth((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRK‚s   cC@stj|t|ƒ|ƒS(N(RJt __setitem__RH(R>RLtvalue((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRNˆscC@stj|t|ƒƒS(N(RJt __delitem__RH(R>RL((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRP‹s(RBRCRKRNRP(((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyR€s  cO@s)tt|ƒj||ŽdtjƒdS(Ntfile(tprinttstrR)R*tstderr(tmtfargstfkwargs((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRscC@s)tjdƒ}t|ƒtd|jƒS(Nitbytes(tctypestcreate_string_bufferR Rtraw(tbuffer((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyR”s cC@s ttƒƒS(sŠGenerate a unique id, having - hopefully - a very small chance of collision. For now this is provided by :func:`uuid.uuid4`. (RSR(((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyR›siiicC@s|S(N((R4((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyR§scC@std„t|ƒDƒƒS(s Make sure keyword arguments are not in Unicode. This should be fixed in newer Python versions, see: http://bugs.python.org/issue4978. cs@s*|] \}}|jdƒ|fVqdS(sutf-8N(tencode(t.0RLRO((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pys ±s(RJR (R4((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRªs cC@s*|dkrgSt|dƒr#|S|gS(Nt__iter__(R"thasattr(tv((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRµs  gð?cc@sM|d}x<| s ||kr2|V||7}q |s<Pn||Vq WdS(Ngð?((tstarttstoptstept repeatlasttcur((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyR½s  gY@cc@sad|d}}xI||kr$Pn|V|rEt|||ƒ}n ||7}||7}qWdS(Nigð?(tmin(RbRcRdtmaxtsum_Rf((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRÉs  ic C@s d} t||||dtƒ} xätƒD]Ù} y|||ŽSWq,|k r} |rm| |krm‚n| r}| ƒnt|r˜|| | | ƒn t| ƒƒ} | rx4tt| ƒƒD] }| rÖ| ƒntdƒqÀWttt| ƒ| ƒƒqq,Xq,WdS(sgRetry the function over and over until max retries is exceeded. For each retry we sleep a for a while before we try again, this interval is increased for every retry until the max seconds is reached. :param fun: The function to try :param catch: Exceptions to catch, can be either tuple or a single exception class. :keyword args: Positional arguments passed on to the function. :keyword kwargs: Keyword arguments passed on to the function. :keyword errback: Callback for when an exception in ``catch`` is raised. The callback must take two arguments: ``exc`` and ``interval``, where ``exc`` is the exception instance, and ``interval`` is the time in seconds to sleep next.. :keyword max_retries: Maximum number of retries before we give up. If this is not set, we will retry forever. :keyword interval_start: How long (in seconds) we start sleeping between retries. :keyword interval_step: By how much the interval is increased for each retry. :keyword interval_max: Maximum number of seconds to sleep between retries. iRegð?N( RtTrueRtfloattnexttrangetintRtabs(tfuntcatchtargsR4terrbackt max_retriestinterval_startt interval_stept interval_maxtcallbacktretriestinterval_rangeR9tttsR6((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRÖs(  c C@sÜddlm}ddlm}|dkrDddl}|j}n|ƒ}td|ƒ||dƒ}zWy|||ddƒWn9tk r¾}td|ƒ|j t ||ƒƒƒnXWd|j ƒ|j ƒX|S(Ni(tpformat(tmktemps&EMERGENCY DUMP STATE TO FILE -> {0} <-twtprotocols0Cannot pickle state: {0!r}. Fallback to pformat.( tpprintR|ttempfileR}R"tpickletdumpRt ExceptiontwriteR tflushtclose( tstatet open_fileRƒR|R}R‚tpersisttfhR9((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRs"      !  cB@sSeZdZddddd„Zdd„Zd„Zd„Zd„Zd„Z RS(s‚Property descriptor that caches the return value of the get function. *Examples* .. code-block:: python @cached_property def connection(self): return Connection() @connection.setter # Prepares stored value def connection(self, value): if value is None: raise TypeError('Connection must be a connection') return value @connection.deleter def connection(self, value): # Additional action to do at del(self.attr) if value is not None: print('Connection {0!r} deleted'.format(value) cC@sI||_||_||_|p'|j|_|j|_|j|_dS(N(t_cached_property__gett_cached_property__sett_cached_property__delRDRBRC(R>tfgettfsettfdeltdoc((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyR@7s     cC@sX|dkr|Sy|j|jSWn/tk rS|j|ƒ}|j|j<|SXdS(N(R"t__dict__RBtKeyErrorRŒ(R>tobjttypeRO((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyt__get__?s  cC@sH|dkr|S|jdk r4|j||ƒ}n||j|jR•RO((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyt__set__Hs  cC@sc|dkr|Sy|jj|jƒ}Wntk r<n#X|jdk r_|j||ƒndS(N(R"R“tpopRBR”RŽ(R>R•RO((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyt __delete__Os  cC@s|j|j||jƒS(N(t __class__RŒRŽ(R>R((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pytsetterZscC@s|j|j|j|ƒS(N(R›RŒR(R>R‘((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pytdeleter]sN( RBRCRDR"R@R—R˜RšRœR(((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRs  s, s{0}={1}c@s#|j‡fd†t|ƒDƒƒS(Nc3@s-|]#\}}ˆj|t|ƒƒVqdS(N(R)t _safe_repr(R^tkRa(tfmt(s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pys bs(tjoinR (R4R2R ((R s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRascC@sIdj||jtt|pdƒƒ|r6|r6|p9dt||ƒƒS(Ns{0}({1}{2}{3})t((R)R¡tmapRžR(R/RrR4R2((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRescg@sûg}g}d}zÞzcyIx=|D]5}|j}|j}|j|ƒƒ|j|ƒq"W|VWntjƒ}nXWdxE|rÂ|jƒ}y||Œr¨d}nWq~tjƒ}q~Xq~W|dkrît|d|d|dƒnXWd~XdS(sKCombine multiple context managers into a single nested context manager.Niii(NNN(NNN(NNN(R"t__exit__t __enter__tappendR*R+R™R (tmanagerstexitstvarsR9tmgrtexittenter((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRms0         $cc@sCt|ƒ}tj}x'tdƒD]}||ƒ|dVq"WdS(Ni(tlisttrandomtshuffleRR"(titR¯R6((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyt shufflecycles    cC@sCyddlm}Wntk r.tgƒSXd„||ƒDƒS(Ni(titer_entry_pointscs@s!|]}||jƒfVqdS(N(tload(R^tep((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pys s(t pkg_resourcesR²R-titer(t namespaceR²((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyt entrypoints˜s   tChannelPromisecB@s#eZd„Zd„Zd„ZRS(cC@s ||_dS(N(t __contract__(R>tcontract((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyR@¢scC@s7y |jSWn%tk r2|jƒ}|_|SXdS(N(t __value__R.Rº(R>RO((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyt__call__¥s   cC@s<yt|jƒSWn$tk r7djt|jƒƒSXdS(Ns(treprR¼R.R)tidRº(R>((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyt__repr__¬s (RBRCR@R½RÀ(((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyR¹ s  R¢c@sdj‡fd†|DƒƒS(NR¢c3@sI|]?}|jƒs!|ˆkr'|n|dkr9dnd|VqdS(ss\000s\N(tisalnum(R^tc(twhite(s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pys µs(R¡(tpRÃ((RÃs6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyt escape_regex³scC@s t|tjƒr|S|jƒS(N(R%tnumberstIntegralR(tf((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRºscC@s&yt|ƒSWntk r!nXdS(s3Get object fileno, or :const:`None` if not defined.N(Rt FILENO_ERRORS(RÈ((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pyRÀs (iii((BRDt __future__RRR#RÆR®R*t contextlibRt itertoolsRRt functoolsRttimeRRRRR R-R"t kombu.fiveR R R tencodingR RRžRYtioRR.R(RÉt__all__R:R­R;RHRJRRt gen_unique_idt version_infoRRtFalseRRRtopenRtobjectRRRRR±R¸R¹RÅRR(((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/__init__.pytsv          ;          /D#