AXj+ d dl mZ d dlZd dlZd dlZd dlmZ d dlmZm Z d dl
Z
ddl m Z m
Z
mZmZ ddlmZmZ dd lmZ dd
lmZ dd lmZmZ g d Zd
ZdZ ej: e Z d dZ d dZ!d dZ"d dZ#d dZ$deddddd d!dZ%ddd"dZ&deddddd d#dZ'dd d$dZ(y)% ) annotationsN)uuid4)Iterator
AsyncIterator )TRANSIENT_ERRORSjitterbackoffis_fatal_status_error )Headersomit)APIStatusError)BetaSelfHostedWork)Work AsyncWork) iter_work
aiter_work
POLL_BLOCK_MSi g N@c $ t | t S )N)cap)r
_POLL_BACKOFF_CAP)attempts h/var/www/html/content_generation/venv/lib/python3.12/site-packages/anthropic/lib/environments/_poller.py_backoffr s 7 1 22 c t | | S N)r )lowhighs r _jitterr! " s #t r c t | S r )r )errs r
_is_fatal_4xxr$ & s
%%r c D t | t xr | j |k( S r )
isinstancer status_code)r# codes r
_is_statusr) * s c> * Fs$/FFr c ^ t j dt j d d S )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 # K |xs
t }t j d||| d}d} | j |||nt ||nt || }
d}|
9|rt j d
| yt j t dd et j d |
j t |
j d
d | j! |
j || d} |s|
|
| j% |
j || # t
$ rw} t
| rt j d| |dz
}t | t dd z } t j d || | t j | Y d} ~ cd} ~ ww xY w# t
$ r} t
| r@t j d|
j | t# | |
j || Y d} ~ | dz
} t | t dd z } t j d|
j | | | t j | Y d} ~ d} ~ ww xY w# t& $ r8} t) | d s!t j d|
j | Y d} ~ wd} ~ ww xY w# | j% |
j || w # t& $ r<} t) | d s&t j d|
j | Y d} ~ w Y d} ~ w d} ~ ww xY wxY ww)u 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
FX]_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
FX]_hiLK
%-%9t?T?`&;fj$- + # D <:NK++gc3 /0 0 0 7'$))U[]aBbc (( - +
" J OJ
OiiGG#1"/ i Q 2F53F>8M>GM G JAJ H J "M(AJ JJ M JMJ K -K
MKMM
!L>L?LM
M
-M;
M
M
M
Mc K | j ||d| d{ y7 # t $ r2}t |d s t j d|| Y d}~yY d}~yd}~ww xY ww)z-Async version of :func:`_force_stop_quietly`.Tra NrI rc rd re s r ri ri
s] aiidZgihhh a!S! IISU\^_ ` ` "as6 A"$ "$ A"$ A #A
A"A A")r intreturnfloat)r rm r rm rl rm )r# rX rl bool)r# rX r( rk rl rn )rl str)rZ r rF ro r2
str | Noner3
int | Noner4 rq r5 rn r6 rn r7 Headers | Nonerl z Iterator[BetaSelfHostedWork])
rZ r rf ro rF ro r7 rr rl None)rZ r rF ro r2 rp r3 rq r4 rq r5 rn r6 rn r7 rr rl z!AsyncIterator[BetaSelfHostedWork])
rZ r rf ro rF ro r7 rr rl rs ))
__future__r rP r- logginguuidr collections.abcr r rh _retryr r r
r _typesr
r _exceptionsr types.beta.environmentsr resources.beta.environments.workr r __all__r r getLogger__name__rK r r! r$ r) r1 r rV r ri r0 r r r s "
3 M M # ) 9 ?
g!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