"j*SSKJr SSKrSSKrSSKrSSKrSSKJrJ r SSK J r SSK J r SSK r SSKJr Sr\R""S 5rS rSSS jjrSSS jjr\"S S55r\"SS55r\"5rg)) annotationsN) dataclassfield)time) TracebackType) data_snapshot)DEFAULT_UPDATE_URL UpdatePriceswait_prices_updated_syncwait_prices_updated_asyncz genai-priceszdhttps://raw.githubusercontent.com/pydantic/genai-prices/refs/heads/main/prices/new_data/v2/data.jsonc[R [RS:Xa SSS5 gSSS5 [RU5$!,(df  N#=f)aWait for an update from the shared background task. If the latest fetch failed, this raises its error while at least one instance is started. Args: timeout: Maximum wait in seconds, or `None` to wait indefinitely. Returns: True if prices were updated, False otherwise. rNF)_shared_updaterlock ref_countwaittimeouts W/home/mande/repo/quber/.venv/lib/python3.13/site-packages/genai_prices/update_prices.pyr r sJ     $ $ )   )     ((  s A AcT# [R"[U5IShvN $N7f)a'Wait asynchronously for an update from the shared background task. If the latest fetch failed, this raises its error while at least one instance is started. Args: timeout: Maximum wait in seconds, or `None` to wait indefinitely. Returns: True if prices were updated, False otherwise. N)asyncio to_threadr rs rr r -s!""#;WE EE Es (&(c\rSrSr%SrSrS\S'\rS\S'\ "SS 9r S \S '\ "S S S S S 9r S\S'S S.SSjjr SSSjjr SrSrSSjrSSjrSrg)r ;aUpdate prices in one background task shared by all instances. Each instance keeps the task running from `start()` until `stop()`. When an instance starts, it supplies the settings and `fetch()` method for future fetches. Calling `start()` while it is already started only waits if requested. Fetched prices stay in use. Use this as a context manager or call `start()` and `stop()` yourself. ifloatupdate_intervalstrurlc,[R"SSS9$)N )rconnect)httpx2TimeoutrUpdatePrices.JsFNN[]ghDir&default_factoryzhttpx2.Timeoutrequest_timeoutF)defaultinitreprcomparebool_started)rc[R UR(d[RU5 SUlSSS5 U(a USLaSOUS9 gg!,(df  N1=f)a8Start this instance and keep the background task running. Future fetches use this instance's settings and `fetch()` method. Calling `start()` while it is already started only waits if requested. Args: wait: `True` to wait up to 30 seconds, a number to wait that many seconds, or `False` to return at once. TNr)rrr1acquirer)selfrs rstartUpdatePrices.startOsZ ! !==''- $ "   tt| F  " !s .A** A8NcPUR(dg[RU5$)aWait for a background price update. If the latest fetch failed, this raises its error while this instance is started. Args: timeout: Maximum wait in seconds, or `None` to wait indefinitely. Returns: True if prices were updated, False otherwise. F)r1rr)r5rs rrUpdatePrices.wait_s}}##G,,r&c[R UR(d SSS5 gSUl[R5 SSS5 g!,(df  g=f)aUStop this instance from keeping the background task running. `stop()` does not wait for the task or raise fetch failures. The task exits when no instances are started and any current fetch is finished. Any prices returned by that fetch are used. Fetched prices stay in use. Calling `stop()` on an instance that is not started does nothing. NF)rrr1releaser5s rstopUpdatePrices.stopns@ ! !==" !"DM  # # % " ! !sAA Ac&UR5 U$N)r6r<s r __enter__UpdatePrices.__enter__{s  r&c$UR5 gr@)r=)r5_argss r__exit__UpdatePrices.__exit__s  r&c:SSKJn [R"URUR S9nUR 5 [R"UR5n[U[5(d [S5eU"U5n[R"USS9$)z9Fetches the latest provider data from the configured URL.r)_providers_from_rawrz6Expected fetched prices payload to be a provider arrayT)from_auto_update)typesrHr#getrr+raise_for_statusjsonloadscontent isinstancelist ValueErrorr DataSnapshot)r5rHr raw_payload providerss rfetchUpdatePrices.fetchss. JJtxx)=)= > jj+ +t,,UV V' 4 )))dKKr&)r1)rz bool | floatr@rz float | Nonereturnr0)rDobject)rZz!data_snapshot.DataSnapshot | None)__name__ __module__ __qualname____firstlineno____doc__r__annotations__r rrr+r1r6rr=rArErW__static_attributes__r%r&rr r ;sq"OU!0!C!'&+>Q DL IIMMO r&c[R"5URLa [S5eURR US9(dgUR nUcgUup4UbURU5eg)Nz3UpdatePrices background task cannot wait for itselfrFT)rscurrent_threadrh RuntimeErrorrjrrkwith_traceback)r5rrkerrorerror_tracebacks rr_SharedUpdater.waitsm  # # % 4TU Uzzw/,, ?!(  &&7 7r&cfXb UROS4UlURR5 gr@) __traceback__rkrjr{)r5rs r_publish_SharedUpdater._publishs'6Gu22TR  r&c<[R"5n[RS5 UR UR ULaSSS5 [RS5 gUR nUc@SUlURR5 SSS5 [RS5 gURR5 SSS5 URW5 URR#WR$5 M!,(df  NG=f![aEnURU5 [RS[U5R U5 SnANSnAff=f![&alnUR UR ULa)SUl[)S5nX4lURU5 SSS5 SnAO!,(df  SnAO =fSnAff=f[RS5 g![RS5 f=f)z@The thread body: fetch while any instance is started, then exit.z%Starting genai-prices background taskNz$genai-prices background task stoppedz6Error updating genai-prices in the background (%s): %sz4UpdatePrices background task terminated unexpectedly)rsr~rprqrrhrgrjr{rirr_update_prices Exceptionrrtyper\rrrvr __cause__)r5mergers rru_SharedUpdater._runs  % % ' @ KK? @YY{{",4 KK> ?-#llG&*  (4 KK> ?!IIOO%p''0 w667#Y!pMM!$LL!Y[_`a[b[k[kmnoop );;"$"&DK()_`E&'OMM%(  ) KK> ?FKK> ?s"E5D E5(1DE57DE5D#+'E5 D E5# E2-;E-(E5-E22E55 G+? G& 9GG& H G# G&H#G&&G++HHc0[5nUR5n[5U- nU(a+[RS[ UR 5U5 O[RSU5 [ R"U5 URS5 g)Nz1Successfully fetched %d providers in %.2f secondsz2Successfully fetched null snapshot in %.2f seconds) rrWrprqlenrVr set_custom_snapshotr)r5rgr6snapshotintervals rr_SharedUpdater._update_pricessi==?6E>  KKKSQYQcQcMdfn o KKLh W))(3 dr&)rgrkrh)rwr rZNone)rZrrY)rzException | NonerZr)rgr rZr)r\r]r^r_r`rrsLockrrarrgrhEventrirjrkr4r;rrrurrbr%r&rrdrds !@D.@Is)#'G 'f&*F #*,!)//BD/BW"9??CE?CNDHG AHH@" @D r&rdr@rY) __future__r _annotationsrrMloggingrs dataclassesrrrrJrr#r __all__ getLoggerrpr r r r rdrr%r&rrs2 (     > *j )" F QLQL QLh }} }@!"r&