_j3SSKJr SSKrSSKrSSKrSSKrSSKJrJrJ r J r J r J r J r JrJr SSKJr SSKJrJr SSKJrJr SSKrSSKJrJrJrJrJr \ "S 5r\ "S \\S 4S 9r \ "S \ \!\4S 9r"\ "S\ \S 9r#\ "S\ S \4S 9r$SSjr'S?Sjr(S@Sjr)SASjr*SBSjr+SCSjr,SDSjr-SESjr.SFSjr/SGSjr0SHSjr1SISjr2SJS jr3S!S"S#.SKS$jjr4SLS%jr5SMS&jr6\ "S'5r7\ "S(5r8\SNS)j5r9\SOS*j5r9\SPS+j5r9SQS,jr9SRS-jr:SSS.jr;STS/jrSWS2jr?SXS3jr@SYS4jrASZS5jrBS[S6jrCS\S7jrDS8S9.S]S:jjrES^S;jrFg)_) annotationsN) AnyTupleMappingTypeVarCallableIterableSequencecastoverload)Path)datedatetime) TypeGuardget_args)OmitNotGiven FileTypes ArrayFormat HeadersLike_T_TupleT.)bound _MappingT _SequenceT CallableTcHUVVs/sH oHo"PM M snn$s snnfN)tsublistitems K/home/rurouni/.local/lib/python3.13/site-packages/parallel/_utils/_utils.pyflattenr%!s" ! 6WgdDgD 66 6sbrackets) array_formatc R/nUHnUR[XSSUS95 M U$)aRecursively extract files from the given dictionary based on specified paths. A path may look like this ['foo', 'files', '', 'data']. ``array_format`` controls how ```` segments contribute to the emitted field name. Supported values: ``"brackets"`` (``foo[]``), ``"repeat"`` and ``"comma"`` (``foo``), ``"indices"`` (``foo[0]``, ``foo[1]``). Note: this mutates the given dictionary. rNindex flattened_keyr')extend_extract_items)querypathsr'filespaths r$ extract_filesr2%s0$*,E ^Eq[ghi Lc US:XagUS:XaSUS3$US:XdUS:Xag[S US S R[[5535e) Nr&z[]indices[]repeatcommazUnknown array_format value: z, choose from , )NotImplementedErrorjoinrr)r' array_indexs r$ _array_suffixr?=sez!y ;-q!!x<7#:  &|nN499XVaMbCcBde r3c XnUS- n[U5(aM[SXS55(aURU5n OXn UcUnO USUS3- n[U UUUUS9$[ U5(aMUS :wa/$[[ U5VV s/sH#up[U UUUbUOS [ XH5-US9PM% sn n5$/$![a [U5(d/s$SSKJn Uce[ U5(aY/n[ U5HDup[ XH5n U(aX:-OU n U"XS9 URU [[U 545 MF Us$U"XS9 U[[U54/s$f=f![a /s$f=fs sn nf) Nr)assert_is_file_content)keyc3*# UH oS:Hv M g7f)Nr ).0ps r$ !_extract_items..qs8entrysuffix emitted_keyr#s r$r-r-Ks7k0 QJEs|| 84<888wws|x  M qQZ 'M  '%     ) I*33 *8%K*7*C}]iOww!-*8   II 7}}I 4((( 3<<13E&/n" &|A:G}5V &u> k4 5+ABC '5 Ls6Y 4566+7@ I  * s;C*E8E8*F E5%A2E5E54E58 FFcd[U[5(+=(a [U[5(+$r) isinstancerrrTs r$rKrKs!#x( ( FC1F-FFr3c"[U[5$rrYtuplerZs r$is_tupler^ c5 !!r3c"[U[5$rr\rZs r$ is_tuple_trar_r3c"[U[5$rrYr rZs r$ is_sequencerd c8 $$r3c"[U[5$rrcrZs r$ is_sequence_trgrer3c"[U[5$rrYrrZs r$ is_mappingrj c7 ##r3c"[U[5$rrirZs r$ is_mapping_trmrkr3c"[U[5$r)rYdictrZs r$rPrP c4  r3c"[U[5$r)rYstrrZs r$is_strrss c3 r3c"[U[5$r)rYlistrZs r$rMrMrpr3c"[U[5$r)rYr rZs r$ is_iterablerwrer3r;or)delimfinalc[U5nUS:XagUS:XaUS$US:XaUSSUSUS3$URUSS5SUSUS3-$)Nrr:rCr )lenr=)seqryrzsizes r$ human_joinrsv s8D qy qy1v  qya&5'3q6(++ ::c#2h AeWAc"gY"7 77r3cSUS3$)zOAdd single quotation marks around the given string. Does *not* do any escaping.'r )strings r$quoters vha=r3c^SU4SjjnU$)aDecorator to enforce a given set of arguments or variants of arguments are passed to the decorated function. Useful for enforcing runtime validation of overloaded functions. Example usage: ```py @overload def foo(*, a: str) -> str: ... @overload def foo(*, b: bool) -> str: ... # This enforces the same constraints that a static type checker would # i.e. that either a or b must be passed to the function @required_args(["a"], ["b"]) def foo(*, a: str | None = None, b: bool | None = None) -> str: ... ``` c8>^^[R"T5RnUR5VVs/sH/up#URUR UR 1;dM-UPM1 snnm[R"T5SUUU4Sjj5nU$s snnf)Ncn>^ [5m [U5Hup#T RT U5 M UR5HnT RU5 M TH!n[U 4SjU55nU(dM! O [ T5S:aM[TVVs/sH-nS[UVs/sHn[U5PM snSS9-S -PM/ snn5nS US 3n Ot[ T5S :de[[TS 5T - 5n [ U 5S:a)S [U Vs/sHn[U5PM sn53n OS[U S 53n [ U 5eT "U0UD6$![a2 [ T R S[ T 5S[ U5S35Sef=fs snfs snnfs snf)Nz () takes z argument(s) but z were givenc3,># UH oT;v M g7frr )rFparam given_paramss r$rH@required_args..inner..wrapper..sJ' 4'srC(and)rz)z,Missing required arguments; Expected either z arguments to be givenrzMissing required arguments: zMissing required argument: ) setrNaddrJ TypeError__name__r~keysrQrrru)argskwargsi_rBvariantmatchesarg variationsmsgmissingrfunc positionalvariantss @r$wrapper-required_args..inner..wrappers%(UL!$  $$Z]3({{}  %%$J'JK7$ x=1$!+muvmubiz*I#5:*IQVWWZ]]muv"JI TjkCx=1,,,#3x{#3l#BCG7|a' .inners""4(33 &||~ - zz%%++ -   ! )! ) ! )F] s ,B'B)rrrrr )rrs` r$ required_argsrs,0d Lr3_K_Vcgrr rZs r$strip_not_givenr5s(+r3cgrr rZs r$rr9sFIr3cgrr rZs r$rr=s,/r3cUcg[U5(dU$UR5VVs0sHup[U[5(aMX_M snn$s snnf)zHRemove all top-level keys where their values are instances of `NotGiven`N)rjrrYr)rTrBvalues r$rrAsE { c?? ), X:3Juh%get_required_header..s##))A,STI[I[I]:]r3zCould not find z header) lowerrmrrYrrresub capitalizerget ValueError)headersheader lower_headerkvintercaps_headernormalized_headerrs r$get_required_headerrs<<>LGMMODAwwyL(Z3-?-?$ vvn.]_e_p_p_rs$FLLNDTU -. 5LV vhg6 77r3cN[R"5$![a gf=f)Nfalse)sniffiocurrent_async_library Exceptionr r3r$get_async_libraryrs(,,.. s  $$maxsizecJ[R"US9n[[U5$)zeA version of functools.lru_cache that retains the type signature for the wrapped function arguments. r)r lru_cacher r)rrs r$rrs&!!G W r3c[U5(a8UR5VVs0sHup[U5[U5_M snn$[U5(a<[ U[ [ [45(dUVs/sHn[U5PM sn$[ U[[45(aUR5$U$s snnfs snf)znTranslates a mapping / sequence recursively in the same fashion as `pydantic` v2's `model_dump(mode="json")`. ) rjr json_saferwrYrrbytes bytearrayrr isoformat)datarBrr#s r$rrs$CG::<Prrrr) rTrr1 Sequence[str]r*rr+ str | Noner'rrr)rTz_T | NotGiven | Omitrz TypeGuard[_T])rTrrzTypeGuard[tuple[object, ...]])rTz_TupleT | objectrzTypeGuard[_TupleT])rTrrzTypeGuard[Sequence[object]])rTz_SequenceT | objectrzTypeGuard[_SequenceT])rTrrzTypeGuard[Mapping[str, object]])rTz_MappingT | objectrzTypeGuard[_MappingT])rTrrzTypeGuard[dict[object, object]])rTrrzTypeGuard[str])rTrrzTypeGuard[list[object]])rTrrzTypeGuard[Iterable[object]])rrryrrrzrrrrr)rrrrrr)rrr Callable[[CallableT], CallableT])rTNonerr )rTzMapping[_K, _V | NotGiven]rz dict[_K, _V])rTrrr)rTz object | Nonerr)rrrrr)rrrrr)rrrrbool)rrr int | None)rrrz float | None)rrrz bool | None)rrrrrrrrr)rrrrVrrrrr)r1rrrr)rrrrrrrr)rrr)rr rr )rrrr)G __future__rrrrrtypingrrrrrr r r r pathlibr rrtyping_extensionsrrr_typesrrrrrrrrrrrrrr%r2r?r-rKr^rardrgrjrmrPrsrMrwrrrrrrrrrrrrrrrrrrrr r3r$rs"    #1HH T] )5#5 6 KwsF{'; < \&)9 : KxS'9 : 7!+   #   !0 N N N  N  N  N!NbG""%%$$! !% 48d 8 HV T] T] + + I I / /Y6   ! 8&(+ r3