sSSKrSSKJrJrJrJr SSKJrJr SSK J r \"S5r S\ S\4Sjr "S S 5r"S S 5rg) N) AwaitableTypeVarOptionalCallable)GoogleAPICallErrorUnknown)wait_ignore_errorsTereturncF[U[5(aU$[SU/S9$)NzHad an unknown error)errors) isinstancerr)r s Klib/third_party/google/cloud/pubsublite/internal/wire/permanent_failable.py adapt_errorrs%!'(( )1# 66c.\rSrSrS\4SjrSrSrSrg)_TaskWithCleanupac:[R"U5UlgN)asyncio ensure_future_task)selfrs r__init___TaskWithCleanup.__init__ s**1- rc"# UR$7frrrs r __aenter___TaskWithCleanup.__aenter__#szzs c# URR5(d8URR5 [UR5IShvN ggN7fr)rdonecancelr )rexc_typeexc_valexc_tbs r __aexit___TaskWithCleanup.__aexit__&s@zz  JJ   $TZZ0 0 0! 0sAAAAr N) __name__ __module__ __qualname____firstlineno__rrr"r*__static_attributes__rrrrs.).1rrc\rSrSr%Sr\\R\S'Sr \ S\R4Sj5r S\ \ S\ 4SjrS \/\ S 44S jrS \4S jrS\\4SjrSrg )PermanentFailable,zdA class that can experience permanent failures, with helpers for forwarding these to client actions._maybe_failure_taskcSUlgrr5r!s rrPermanentFailable.__init__1s #' rr chURc[R"5UlUR$)zaGet the failure task, initializing it lazily, since it needs to be initialized in the event loop.)r5rFuturer!s r _failure_taskPermanentFailable._failure_task4s+  # # +'.~~'7D $'''r awaitablec# [U5IShvN nURR5(aURR5e[R "X R/[R S9IShvN up4X#;aUIShvN sSSS5IShvN $URR5eNNBN3N%!,IShvN (df  g=f7f)z Await the awaitable, unless fail() is called first. Args: awaitable: An awaitable Returns: The result of the awaitable Raises: The permanent error if fail() is called or the awaitable raises one. N) return_when)rr;r% exceptionrwaitFIRST_COMPLETED)rr=taskr%_s rawait_unless_failed%PermanentFailable.await_unless_failed;s$I..$!!&&((((2244#LL))*8O8OGD|!z/..$$..0 0/"/...suC$CC$A+C CC CC  C$"C#C$(C C$C C C$ C!C  C!C$ poll_actionNc# URU"55IShvN M N![Ra g[a$nUR [ U55 SnAgSnAff=f7f)z Run a polling loop, which runs poll_action forever unless this is failed. Args: poll_action: A callable returning an awaitable to run in a loop. Note that async functions which return once satisfy this. N)rErCancelledError Exceptionfailr)rrGr s r run_pollerPermanentFailable.run_pollerNs^ &..{}====%%   & IIk!n % % &s8A-'%'A*A- A*A% A-%A**A-errcURR5(d6URRU5 URR5 ggr)r;r% set_exceptionr@)rrNs rrKPermanentFailable.fail]sD!!&&((    , ,S 1    ( ( * )rcvURR5(dgURR5$r)r;r%r@r!s rerrorPermanentFailable.errords/!!&&((!!++--rr7)r,r-r.r/__doc__rrr:__annotations__rpropertyr;rr rErrLrrKrSr0r1rrr3r3,sn!'..11((w~~(( 19Q<1A1& &HR45H,I &+*+.x 23.rr3)rtypingrrrrgoogle.api_core.exceptionsrr6google.cloud.pubsublite.internal.wait_ignore_cancelledr r rJrrr3r1rrr[sG99BU CL797!37 1 1;.;.r