o i @s:UdZddlmZddlZddlZddlZddlmZmZm Z m Z m Z ddl m Z ddlmZe r9ddlmZmZgd Ze d Ze d ZeegefZd ed <e dZe dZeejdddRddZeejdd dSdddTddZeejjdUd!d"Zee_eejdddVd&d'Zeej dddWd(d)Z eej!dddXd,d-Z!eej"dddYd/d0Z"eej#dddZd3d4Z#ej$d5kreej%ddd[d7d8Z%ed8g7Zeej&d\d]dd?d^dDdEZ'e d_dIdEZ'e d>d?d`dKdEZ'e dadNdEZ'e d>d?dbdPdEZ'eej'dddd?dcdQdEZ'dS)dz Python polyfills for itertools ) annotationsN)CallableOptionaloverload TYPE_CHECKINGTypeVar) TypeAlias)substitute_in_graph)IterableIterator) accumulatechainchain_from_iterablecompresscycle dropwhile filterfalseislicetee zip_longest_T_Ur _Predicate_T1_T2T)is_embedded_type iterables Iterable[_T]return Iterator[_T]cg|D]}|EdHqdSN)riterabler#r#^/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/torch/_dynamo/polyfills/itertools.pyr*s r)initialr$func Optional[Callable[[_T, _T], _T]]r& Optional[_T]cs.t|}dur tjdfdd }||S)Niteratorr rc3sT}|durzt|}Wn tyYdSw|V|D] }||}|VqdSr"next StopIteration)r*totalelementr'r&r#r% _accumulate=s   zaccumulate.._accumulater*r rr )iteroperatoradd)r$r'r&r*r1r#r0r%r 1s  r Iterable[Iterable[_T]]ccr!r"r#)r$itr#r#r%rMs rdata selectors Iterable[_U]cCsddt||DS)Ncss|] \}}|r|VqdSr"r#).0datumselectorr#r#r% \szcompress..)zip)r8r9r#r#r%rZsrcst}dfdd }||S)Nr*r rc3s@g}D] }|V||q|r|D]}|Vq|sdSdSr")append)r*savedr/r$r#r%_cycleds  zcycle.._cycler2r3)r$r*rCr#rBr%r`s r predicate_Predicate[_T]ccs4t|}|D] }||s|Vnq|EdHdSr"rD)rEr$r*xr#r#r%rrsrfunctioncs.t|}durttj|Stfdd|S)Ncs | Sr"r#)rGrHr#r%s zfilterfalse..)r3filterr4not_)rHr$r7r#rIr%rs rargs int | Nonec gst|}|jdur dn|j}|j}|jdurdn|j}|dks,|dur(|dks,|dkr0td|durL|}t|D]\}}||krI|V||7}q:dStt||} |}t| |D]\}}||kri|V||7}qZdS)NrzGIndices for islice() must be None or an integer: 0 <= x <= sys.maxsize.) slicestartstopstep ValueError enumeraterangemaxr?) r$rMsrQrRrSnext_iir/indicesr#r#r%rs2 r) Iterator[tuple[_T, _T]]ccs0d}d}|D]}|rd}n||fV|}qdS)NTFr#)r$afirstbr#r#r%pairwises rbninttuple[Iterator[_T], ...]cs:t|ddgdfdd tfddt|DS)Nrr c3sNz |ddurt|d<ddg|d<|\}}|Vqty&YdSw)NTrOrr+)linkvalue)r*r#r%_tees    ztee.._teec3s|]}VqdSr"r#)r;_)rh shared_linkr#r%r>sztee..)rr )r3tuplerV)r$rcr#)rhr*rjr%rs r.) fillvalueiter1 Iterable[_T1]rlIterator[tuple[_T1]]cCdSr"r#)rmrlr#r#r%rsriter2 Iterable[_T2]'Iterator[tuple[_T1 | None, _T2 | None]]cCrpr"r#)rmrqr#r#r%rs#Iterator[tuple[_T1 | _U, _T2 | _U]]cCrpr"r#)rmrqrlr#r#r%riter3Iterator[tuple[_T | None, ...]]cGrpr"r#)rmrqrvrr#r#r%rruIterator[tuple[_T | _U, ...]]cGrpr"r#)rmrqrvrlrr#r#r%rsc gsttt|}t|}|sdS g}t|D],\}}zt|}Wnty=|d8}|s2YdSt|||<|}Ynw| |qt |Vq)NTrO) listmapr3lenrUr,r- itertoolsrepeatr@rk)rlr iterators num_activevaluesrZr*rgr#r#r%rs(    )rrrr r")r$rr'r(r&r)rr )r$r6rr )r8rr9r:rr )r$rrr )rErFr$rrr )rHrFr$rrr )r$rrMrNrr )r$rrr^)r )r$rrcrdrre)rmrnrlrrro)rmrnrqrrrrs)rmrnrqrrrlrrrt) rmrrqrrvrrrrrw) rmrrqrrvrrrrlrrrx)rrrlrrrx)(__doc__ __future__rr|r4systypingrrrrrtyping_extensionsr decoratorsr collections.abcr r __all__rrobjectr__annotations__rrrr from_iterablerrrrrr version_inforbrrr#r#r#r%st