b\j+ S SK Jr S SKrS SKrS SKrS SKJr S SKJrJ r S SK
r
SSK J r J
r
JrJr SSKJrJr SS KJr SS
KJr SS KJrJr / S QrS
rSr \R: " \ 5 r S S jr S S jr!S S jr"S S jr#S S jr$S\SSSSS. S!S jjr%SS.S"S jjr&S\SSSSS. S#S jjr'SS. S$S jjr(g)% ) annotationsN)uuid4)Iterator
AsyncIterator )TRANSIENT_ERRORSjitterbackoffis_fatal_status_error )Headersomit)APIStatusError)BetaSelfHostedWork)Work AsyncWork) iter_work
aiter_work
POLL_BLOCK_MSi g N@c [ U [ S9$ )N)cap)r
_POLL_BACKOFF_CAP)attempts X/var/www/website/venv/lib/python3.13/site-packages/anthropic/lib/environments/_poller.py_backoffr s 7 1 22 c [ X5 $ N)r )lowhighs r _jitterr! " s
# r c [ U 5 $ r )r )errs r
_is_fatal_4xxr$ & s
%%r c N [ U [ 5 =( a U R U:H $ r )
isinstancer status_code)r# codes r
_is_statusr) * s c> * Fs$/FFr c ` [ R " 5 S[ 5 R S S 3$ )N- )socket gethostnamer hex r r _default_worker_idr1 . s- "
#1UW[["%5$6 77r FT) worker_idblock_msreclaim_older_than_msdrain auto_stop
extra_headersc # @ # U=( d
[ 5 n[ R SXU5 SnSn U R UUb UO[ Ub UO[ UUS9n
SnU
c@ U( a [ R S
U5 g[ R " [ SS 5 5 Ml [ R S U
R [ U
R S
S5 5 U R! U
R UUS9 Sn U( d U
v M U
v U R% U
R UUS9 M ! [
a} n [
U 5 ( a [ R SU 5 e US-
n[ U5 [ SS5 - n [ R S XU 5 [ R " U 5 Sn A GMr Sn A ff = f! [
a n [
U 5 ( a< [ R SU
R U 5 [# X
R XS9 Sn A GM U S-
n [ U 5 [ SS5 - n [ R SU
R XU 5 [ R " U 5 Sn A GM, Sn A ff = f! [& a= n [) U S5 ( d! [ R SU
R U 5 Sn A GNSn A ff = f! U R% U
R UUS9 f ! [& aA n [) U S5 ( d& [ R SU
R U 5 Sn A f Sn A f Sn A ff = f= f7f)uK Iterate work items claimed from a self-hosted environment.
Each yielded :class:`BetaSelfHostedWork` has already been ack'd. The ``work``
resource must be bound to a client authenticated for the environment — the
poller itself does not handle credentials. Use
``client.beta.environments.work.poller(...)`` for the user-facing entry
point that constructs a scoped sub-client for you.
Two consumption shapes are supported:
- **Long-running runner** (``drain=False, auto_stop=True``, the default):
loops forever, sleeps with jitter on empty polls, and calls ``work.stop``
when the consuming for-loop body returns or raises. The poller owns the
whole work-item lifecycle.
- **Drain-and-dispatch** (``drain=True, auto_stop=False``): returns as soon
as the queue is empty and never calls ``work.stop`` — use this when each
yielded item is handed off to another process (e.g. a webhook handler
that spawns a sandbox per work item) and that process owns ``stop``.
Args:
block_ms: How long the server holds an empty poll open (long-poll).
Pass ``None`` to omit the param for a non-blocking poll — the server
rejects ``0``. Drain callers usually want ``None`` so the final empty
poll returns immediately.
drain: When True, return after the first empty poll instead of sleeping
and re-polling. Lets a webhook-driven dispatcher drain the queue and
respond.
auto_stop: When True (default), call ``work.stop`` after the consumer's
loop body completes. Set False when the work item is handed off to
another process that owns the stop call — otherwise the lease is
terminated out from under it.
reclaim_older_than_ms: Forwarded to ``work.poll``. Reclaim un-ack'd work
older than this many ms. Useful in drain mode so a dead runner's
work re-surfaces on the next webhook delivery.
extra_headers: Optional headers passed through per request on every
poll / ack / stop call (including the force-stop of an unprocessable
item). They are threaded into each call's ``extra_headers=`` and are
never assigned onto the client, so client state is not mutated.
Credentials and ``x-stainless-helper`` come from the bound client,
not this argument; a header given here overrides the bound client's
same-named default for that one request, so use it for caller
passthrough (e.g. trace ids), not to set auth.
7poller starting environment_id=%s drain=%s auto_stop=%sr Nr3 r4 anthropic_worker_idr7 poll failed permanently error=%s ?-poll failed attempt=%d backoff=%.1fs error=%s queue drained environment_id=%s @$claimed work work_id=%s work_type=%stypeenvironment_idr7 :ack failed permanently; force-stopping work_id=%s error=%sDack failed, backing off work_id=%s attempt=%d backoff=%.1fs error=%s stop failed work_id=%s error=%s)r1 loginfopollr r r$ errorr r! warningtimesleepidgetattrdataack_force_stop_quietlystop Exceptionr)
workrF r2 r3 r4 r5 r6 r7 poll_attempt ack_attemptitemewaits
r r r 5 s l 1 / 1IHH
F_hi LK
99 %-%9t?T?`&;fj$- + D <:NK JJwsC( ) 7'$))U[]aBbc HH - +
" J OJ
O GG#1"/ i Q r? r@ rA rB rC rD rE rG rH rI rJ )r1 rK rL rM r r r$ rN r r! rO anyiorQ rR rS rT rU _aforce_stop_quietlyrW rX r) rY s
r r r s 1 / 1IHH
F_hiLK
%-%9t?T?`&;fj$- + # D <:NK++gc3 /0 0 0 7'$))U[]aBbc (( - +
" J OJ
OiiGG#1"/ i Q r s "
3 M M # ) 9 ?
!3 &G8 !((,$(xO
xO xO xO
xO &
xO xO xO "xO "xOv ko
a" !((,$(MO
MO MO MO
MO &
MO MO MO "MO 'MOb \`a
a !a69aJXa ar