o FÆhKã@sRddlZddlZddlmZddlmZeddGdd„dƒƒZGdd „d ƒZdS) éN)Ú dataclass)Ú normalvariateT)Úfrozenc@s8eZdZUeed<eed<eed<eed<d dd„ZdS) Ú BackoffConfigÚ min_delayÚ max_delayÚfactorÚjitterÚreturnNcCs*|j|jkr tdƒ‚|jdkrtdƒ‚dS)Nz.`max_delay` should be greater than `min_delay`éz!`factor` should be greater than 1)rrÚ ValueErrorr©Úself©rúH/var/www/html/venv/lib/python3.10/site-packages/aiogram/utils/backoff.pyÚ __post_init__s ÿzBackoffConfig.__post_init__©r N)Ú__name__Ú __module__Ú__qualname__ÚfloatÚ__annotations__rrrrrrs rc@sòeZdZdeddfdd„Zd#dd„Zedefdd „ƒZedefd d„ƒZ edefdd „ƒZ edefdd„ƒZedefdd„ƒZedefdd„ƒZ edefdd„ƒZd$dd„Zd$dd„Zdedefdd„Zdefdd„Zd$dd „Zdefd!d"„ZdS)%ÚBackoffÚconfigr NcCs||_|j|_d|_d|_dS©Ngr)rrÚ_next_delayÚ_current_delayÚ_counter)rrrrrÚ__init__s zBackoff.__init__cCs|S©Nrr rrrÚ__iter__szBackoff.__iter__cCó|jjSr)rrr rrrrózBackoff.min_delaycCr!r)rrr rrrr#r"zBackoff.max_delaycCr!r)rrr rrrr'r"zBackoff.factorcCr!r)rr r rrrr +r"zBackoff.jittercCó|jSr)rr rrrÚ next_delay/ózBackoff.next_delaycCr#r)rr rrrÚ current_delay3r%zBackoff.current_delaycCr#r)rr rrrÚcounter7r%zBackoff.countercCst t|ƒ¡dSr)ÚtimeÚsleepÚnextr rrrr);sz Backoff.sleepcÃst t|ƒ¡IdHdSr)Úasyncior)r*r rrrÚasleep>s€zBackoff.asleepÚvaluecCstt||j|jƒ|jƒSr)rÚminrrr )rr-rrrÚ_calculate_nextAszBackoff._calculate_nextcCs*|j|_| |j¡|_|jd7_|jS)Nr)rrr/rr rrrÚ__next__DszBackoff.__next__cCsd|_d|_|j|_dSr)rrrrr rrrÚresetJsz Backoff.resetcCsd|j›d|j›d|j›dS)NzBackoff(tryings=z, current_delay=z , next_delay=ú))rrrr rrrÚ__str__OsÿÿzBackoff.__str__)r rr)rrrrrr Úpropertyrrrrr r$r&Úintr'r)r,r/r0r1Ústrr3rrrrrs. r)r+r(ÚdataclassesrÚrandomrrrrrrrÚs