๓ O'—^c@@sQddlmZddlmZddlZddlZddlmZddlmZddlm Z ddl m Z ddl m Z dd lmZmZmZmZmZmZmZejd,krไdd lmZmZndd lmZmZd efd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZ defd„ƒYZ!defd„ƒYZ"d„Z#defd„ƒYZ$d efd!„ƒYZ%d"efd#„ƒYZ&d$efd%„ƒYZ'd&efd'„ƒYZ(d(efd)„ƒYZ)d*efd+„ƒYZ*dS(-i(tabsolute_import(tunicode_literalsN(twraps(tversion_info_t(tutils(tversion_string_as_tuple(tstring_t(tCasetMocktpatchtredirect_stdoutst mask_modulest module_existstskip_if_modulei(tStringIOtBytesIO(RRt OldStringcB@s,eZd„Zd„Zd„Zd„ZRS(cC@s ||_dS(N(tvalue(tselfR((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt__init__scC@s|jS(N(R(R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt__str__scO@s|jj||ŽS(N(Rtsplit(Rtargstkwargs((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyR!scO@s|jj||ŽS(N(Rtrsplit(RRR((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyR$s(t__name__t __module__RRRR(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRs   ttest_kombu_modulecB@seZd„ZRS(cC@s#ddl}|jt|ƒƒdS(Ni(tkombut assertTruetdir(RR((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_dir*s (RRR(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyR(st test_utilscB@s5eZd„Zd„Zd„Zd„Zd„ZRS(cC@sd|jtjdƒgƒ|jtjdƒdgƒ|jtjdddgƒdddgƒdS(Niii(t assertEqualRt maybe_listtNone(R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_maybe_list1scC@s2|jttjdddƒƒdddgƒdS(Ng๐?g@g@(R!tlistRtfxrange(R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_fxrange_no_repeatlast6sc C@sŠ|jttjddddƒƒdddddddddddg ƒ|jttjddddƒƒdddddddgƒdS( Ng๐?g@g>@g@g@g@g@g@(R!R%Rt fxrangemaxR#(R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_fxrangemax:s !!cC@s/|jtjidd6dd6dd6ƒƒdS(Nubarufooiiuvuk(RRt reprkwargs(R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_reprkwargsAscC@s'|jtjdditd6ƒƒdS(Nuaddiucopy(ii(RRtreprcalltTrue(R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt test_reprcallDs(RRR$R'R)R+R.(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyR /s     t test_UUIDcB@s/eZd„Zd„Zedƒd„ƒZRS(cC@s |jtjƒtjƒƒdS(N(tassertNotEqualRtuuid4(R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt test_uuid4LscC@s<tjƒ}tjƒ}|j|tƒ|j||ƒdS(N(RtuuidtassertIsInstancetstrR0(Rti1ti2((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt test_uuidPs  u__pypy__c@sMtjjdƒ}tdƒ‡fd†ƒ}z |ƒWd|tjd/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pytwith_ctypes_maskedZs    u celery.utils(tsystmodulestpopR (Rt old_utilsR=((Rs>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_uuid_without_ctypesVs   (RRR2R8R RB(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyR/Js  t test_MisccB@seZd„ZRS(cC@s=d„}idd6dd6}|j|tj|ƒƒdS(Nc[@s|S(N((R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pytfmsufooubar(RRtkwdict(RRDtkw((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt test_kwdictks   (RRRG(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRCist MyStringIOcB@seZd„ZRS(cC@sdS(N((R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pytclosews(RRRI(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRHust MyBytesIOcB@seZd„ZRS(cC@sdS(N((R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRI}s(RRRI(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRJ{sttest_emergency_dump_statecB@s&eZed„ƒZed„ƒZRS(c@s|tƒ‰tjidd6d‡fd†ƒ|jtjˆjƒƒidd6ƒ|j|jƒƒ|j|jƒƒdS(Nubarufoot open_filec@sˆS(N((tntm(tfh(s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt‡t( RJRtemergency_dump_statetassertDictEqualtpickletloadstgetvalueRt assertFalse(Rtstdouttstderr((ROs>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt test_dumpƒs  #&c@s‘tƒ‰d„}tjidd6d‡fd†d|ƒ|jdˆjƒƒ|jdˆjƒƒ|j|jƒƒ|j|jƒƒdS(Nc_@stdƒ‚dS(Nufoo(tKeyError(RR((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pytraise_somethingsubarufooRLc@sˆS(N((RMRN(RO(s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRP•RQtdump(RHRRRtassertInRVRRW(RRXRYR\((ROs>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_dump_second_strategyŒs   (RRR RZR_(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRKs c@stˆƒ‡fd†ƒ}|S(Nc@s=d„}tj}|t_zˆ||ŽSWd|t_XdS(NcS@sdS(N((ti((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pytmysleepกs(Rtsleep(RRRat prev_sleep(tfun(s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt_innerŸs    (R(RdRe((Rds>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pytinsomnias ttest_retry_over_timecB@sfeZd„Zdefd„ƒYZd„Zd„Zed„ƒZed„ƒZ ed„ƒZ RS(cC@s d|_dS(Ni(tindex(R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pytsetUpฐst PredicatecB@seZRS((RR(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRjณscC@s"|jdkr|jƒ‚ndS(Ni i*(RhRj(R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pytmyfunถsc C@s<t|ƒ}d }|jd 7_|j|||jƒ|S( Ng@g@g@g @g$@g(@g,@g0@i( Ng@g@g@g @g$@g(@g,@g0@g0@(tnextR#RhR!(Rtexct intervalstretriestintervalt sleepvals((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyterrbackปs  c C@s๏tjtƒ}t_zศttdƒƒtj_tj|j|jddddƒ}|j |ƒttdƒƒtj_tƒ}tj|j|jd|j d|ddƒ}|j |dƒ|j |j dƒ|jƒWd|t_XdS( NiRrt interval_maxii tcallbacki*i (RtcountRR%tranget return_valuetretry_over_timeRkRjR#R;RrR!Rhtassert_called_with(Rt prev_counttxtcb((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt test_simpleยs   cC@sœ|j|jƒ0tj|j|jddd|jddƒWdQX|j|jdƒ|j|jƒ-tj|j|jddddddƒWdQXdS(Nt max_retriesiRrRsi( t assertRaisesRjRRxRkRrR!RhR#(R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_retry_onceีsc @sv|j‰dtf‡fd†ƒY}|ƒ}|jtj||jddddddƒdƒ|j|jd ƒdS( NtFunc@s eZd„Z‡fd†ZRS(cS@s d|_dS(Ni(tcalls(R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyR๊sc@s7z |jdkrdSˆƒ‚Wd|jd7_XdS(Ni i*i(R‚(RRR(Rj(s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt__call__ํs  (RRRRƒ((Rj(s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyR่s R~iRrRsii*i (RjtobjectR!RRxR#R‚(RRRd((Rjs>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_retry_alwaysไs   ( RRRit ExceptionRjRkRrRfR}R€R…(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRgฎs   ttest_cached_propertycB@seZd„Zd„ZRS(cC@s_dtfd„ƒY}|ƒ}|`|j|jƒd|jd<|`|j|jdƒdS(NtXcB@s2eZeZejd„ƒZejd„ƒZRS(cS@sdS(Ni*((R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pytfooscS@s ||_dS(N(txx(RR((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyR‰ s(RRtFalseRŠRtcached_propertyR‰tdeleter(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRˆsuhereufoo(R„R‰RWRŠt__dict__R!(RRˆR{((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt test_deletings  cC@sษdtfd„ƒY}|jd}|j|j|ƒ|j|jdƒ|ƒ|j|jddƒ|ƒ|j|jdƒ|ƒ|j|j dƒƒ|ƒ}d|_|j |j dƒ|`dS(NRˆcB@s2eZdZejd„ƒZejd„ƒZRS(cS@sdS(Ni*((R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyR‰scS@s d|_dS(Ni (RŠ(RR((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyR‰sN(RRR#RŠRRŒR‰tsetter(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRˆsufooiii ( R„RŽtassertIsR‰t__get__R#t__set__t __delete__RRR!RŠ(RRˆtdescR{((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_when_access_from_classs   (RRRR–(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyR‡s ttest_symbol_by_namecB@s5eZd„Zd„Zd„Zd„Zd„ZRS(cC@s&tƒ}|jtj|ƒ|ƒdS(N(R„R‘Rtsymbol_by_name(Rtinstance((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_instance_returns_instance4s cC@s,tƒ}|jtjdd|ƒ|ƒdS(Nuxyz.ryx.qedoa.weq:foztdefault(R„R‘RR˜(RR›((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_returns_default8s cC@s'|jtƒtjdƒWdQXdS(Nuxyz.ryx.qedoa.weq:foz(Rt ImportErrorRR˜(R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_no_default?scC@sBtƒ}tƒ|_|jtƒtjdd|ƒWdQXdS(Nukombu.Connectiontimp(Rt ValueErrort side_effectRRR˜(RRŸ((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_imp_reraises_ValueErrorCs  cC@sOddlm}|jtjdddƒ|ƒ|jtjdddƒƒdS(Ni(tExchangeu.entity:Exchangetpackageukombuu :Consumer(t kombu.entityRฃR‘RR˜R(RRฃ((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt test_packageIs (RRRšRœRžRขRฆ(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyR—2s     ttest_ChannelPromisecB@seZd„ZRS(cC@sBtddƒ}|jdttj|ƒƒƒ|j|jƒdS(Ntnameucbupromise(RR^treprRtChannelPromiseRWtcalled(Rtobj((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt test_reprTs (RRRญ(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRงRsttest_entrypointscB@s2eZedƒd„ƒZedƒd„ƒZRS(u pkg_resourcescC@s#|jttjdƒƒgƒdS(Nu kombu.test(tassertListEqualR%Rt entrypoints(R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_without_pkg_resources_scC@sƒtddtƒk}tƒtƒg}|_|jttjdƒƒƒ|jdƒ|dj jƒ|dj jƒWdQXdS(Nupkg_resources.iter_entry_pointstcreateu kombu.testii( R R-RRwRR%RRฐRytload(Rtiterepteps((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyttest_with_pkg_resourcescs  (RRR RฑR Rถ(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRฎ]sttest_shufflecyclecB@seZd„ZRS(cC@sแtjtƒ}t_zบttdƒƒtj_tdddgƒ}tj|ƒ}tƒ}xtdƒD]}t|ƒqkWtjj dƒ|j |j |ƒƒ|j tƒt|ƒt|ƒWdQXWd|t_XdS(Ni uAuBuC(RtrepeatRR%RvRwtsett shufflecycleRlRyR#RtissubsetRt StopIteration(Rt prev_repeattvaluestcycletseenR`((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt test_shufflesps  (RRRม(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRทnsttest_version_string_as_tuplecB@seZd„ZRS(cC@s๔|jtdƒtdddddƒƒ|jtdƒtdddddƒƒ|jtdƒtdddddƒƒ|jtdƒtdddd dƒƒ|jtd ƒtdddd d ƒƒ|jtd ƒtdddd d ƒƒdS( Nu3iiuu3.3u3.3.1iu3.3.1a3ua3u 3.3.1a3-40c32u40c32u3.3.1.a3.40c32(tassertTupleEqualRRR!(R((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyt test_versions„s$      (RRRฤ(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyRย‚s(ii(+t __future__RRRTR>t functoolsRRRRtkombu.utils.textRt kombu.fiveRtkombu.tests.caseRRR R R R R t version_infotioRRR„RRR R/RCRHRJRKRfRgR‡R—RงRฎRทRย(((s>/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/utils/test_utils.pyts8  4  R2