[j!SSKJr SSKJrJrJrJrJr SSKrSSK J r SSK J r J r /SQrSrS rS rS r"S S 5rSSjrSSjrSSjrSSjrSSjr"SS\\ 5rg)) annotations)AnyListCallableOptional AwaitableN)Job)JobFailedErrorJobWaitTimeoutError)V2ResourceMixinJobListpoll_until_terminalapoll_until_terminalDEFAULT_POLL_INITIALDEFAULT_POLL_MAXDEFAULT_POLL_FACTORDEFAULT_WAIT_TIMEOUTg?g$@g?g@c.\rSrSr%SrS\S'SSjrSrg) r aShared helpers for V2 sub-resources, which target an absolute (non-V1) host. ``_client`` is provided by whichever of ``SyncAPIResource``/``AsyncAPIResource`` this mixes in alongside; it is declared here as ``Any`` only so this mixin's own methods type-check in isolation. r_clientc6URRU3$N)r _v2_base_url)selfpaths ]/home/mande/repo/quber/.venv/lib/python3.13/site-packages/landingai_ade/resources/v2/_base.py_v2_urlV2ResourceMixin._v2_url&s,,++,TF33N)rstrreturnr")__name__ __module__ __qualname____firstlineno____doc____annotations__r__static_attributes__r!r rr r sL4r r c:UbU$[U[-[5$r)minrr)current poll_intervals r _next_delayr/*s"  w,,.> ??r c U(azURbl[SURSURRSURR =(d URR =(d S35egg)NJob z ended z: z unknown error)errorr job_idstatusvaluemessagecode)jobraise_on_failures r_raise_if_failedr:0sfCII13::,gcjj&6&6%7r#)):K:K:psyy~~:pap9q r  2r c PU"5U-nUbUO[nU"5nUR(a [XS9 U$U"5U:a3[SURSUSUR R S35eU"[U[SXa"5- 555 [Xt5nM)a Poll ``get_job`` with backoff until the job reaches a terminal state. ``monotonic``/``sleep`` are injected (rather than reading ``time`` directly) so tests can drive a fake clock without real time passing; production callers pass ``time.monotonic``/``time.sleep``. r9r1 did not finish within s (last status: ).) r is_terminalr:r r3r4r5r,maxr/) get_job monotonicsleeptimeoutr.r9deadlinedelayr8s rrr7s{W$H*6Mr?r@) rrAr:r r3r4r5anyiorEr,rBr/)rCrDrFr.r9rGrHr8s rrrUs{W$H*6Mrks";; @  4 4@  2 2#2 # 2  2 # 22 2<2 )2#2 2 # 2  2 205d3ir