+ ~j~^RIHt^RIt^RIHtHtHtHtHt^RI H t ^RI t ]'d^RI H t ^RIHt^RIHtHt^RIHt^R IHtHtHtHtHtHtHt^R IHtHtH t H!t!H"t"^R I#H$t$^R I%H&t&H't'^R I(H)t)H*t*^RI+H,t,H-t-^RI.H/t/H0t0^RI1H2t2H3t3H4t4H5t5H6t6^RI7H8t8^RI9H:t:^RI;Ht>RR.t?!RR]&4t@!RR]'4tA!RR4tB!RR4tC!RR4tD!RR 4tER#)!) annotationsN) TYPE_CHECKINGDictListOptionalcast)chain) AsyncIterator)AsyncAnthropic)EnvironmentWorkerEnvironmentWorkerTools)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given)is_given path_templatemaybe_transformstrip_not_givenasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncPageCursorAsyncPageCursor)AsyncPaginatormake_request_options)work_list_paramswork_poll_paramswork_stop_paramswork_update_paramswork_heartbeat_params)AnthropicBetaParam)BetaSelfHostedWork)BetaSelfHostedWorkQueueStats)#BetaSelfHostedWorkHeartbeatResponseWork AsyncWorkc]tRt^(t]RRl4t]RRl4tR]RRRRR RR ]/R R llt R]RRRRR RR ]/R Rllt R]R]R]RRRRR RR ]/RRllt R]RRRRR RR ]/RRllt R]R]R]RRRRR RR ]/RRllt R]R]R]R]RRRRR RR ]/RRlltR]RRRRR RR ]/RRlltR ]R]RRRRR RR ]/R!R"lltR#tR#)$r-cV^8dQhRR/#)returnWorkWithRawResponse)formats"/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/anthropic/resources/beta/environments/work.py __annotate__Work.__annotate__*s))#6)c \V4#z This property can be used as a prefix for any HTTP method call to return the raw response object instead of the parsed content. For more information, see https://www.github.com/anthropics/anthropic-sdk-python#accessing-raw-response-data-eg-headers )r3selfs&r6with_raw_responseWork.with_raw_response)s#4((r9cV^8dQhRR/#)r1r2WorkWithStreamingResponser4)r5s"r6r7r84s//)B/r9c \V4#z An alternative to `.with_raw_response` that doesn't eagerly read the response body. For more information, see https://www.github.com/anthropics/anthropic-sdk-python#with_streaming_response )rAr<s&r6with_streaming_responseWork.with_streaming_response3s)..r9betas extra_headersN extra_query extra_bodytimeoutc8V^8dQhRRRRRRRRRR R R R R RR/#r1work_idstrenvironment_idrFList[AnthropicBetaParam] | OmitrGHeaders | NonerH Query | NonerI Body | NonerJ'float | httpx.Timeout | None | NotGivenr2r*r4)r5s"r6r7r8<Z9 9 9  9 / 9 &9 "9  9 99  9 r9c  V'g\RV: 24hV'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ /4CT;'g/CpRR/T;'g/CpVP \RVVR7\WEWgR 7\R 7#)  Note: these endpoints are called automatically by the pre-built environment worker provided in the SDKs and CLI, for orchestrating sessions with self-hosted sandbox environments. They are included here as a reference; you do not need to invoke them directly. Retrieve detailed information about a specific work item. Args: betas: Optional header to specify the beta version(s) you want to use. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds =Expected a non-empty value for `environment_id` but received 6Expected a non-empty value for `work_id` but received anthropic-beta,c38"TFp\V4xK R#5iNrN.0es& r6 Work.retrieve..c5Lec!ffemanaged-agents-2026-04-01:/v1/environments/{environment_id}/work/{work_id}?beta=truerOrMrGrHrIrJoptionscast_to ValueErrorrrjoinr r_getrr#r*r=rMrOrFrGrHrIrJs&&$$$$$$r6retrieve Work.retrieve<s@\]k\nop pUV]U`ab b  $'*hhu5Le5LOjNk/l&m"  ""  *+F`=K^K^\^` yy L-  )+Q['  r9c<V^8dQhRRRRRRRRRR R R R R RRRR/ #r1rMrNrOmetadatazDict[str, Optional[str]]rFrPrGrQrHrRrIrSrJrTr2r*r4)r5s"r6r7r8wd> > >  > + > / > &> ">  > 9>  > r9c  V'g\RV: 24hV'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ /4CT;'g/CpRR/T;'g/CpVP \RVVR7\R V/\P4\WVWxR 7\R 7#)  Note: these endpoints are called automatically by the pre-built environment worker provided in the SDKs and CLI, for orchestrating sessions with self-hosted sandbox environments. They are included here as a reference; you do not need to invoke them directly. Update work item metadata with merge semantics. Args: metadata: Metadata patch. Set a key to a string to upsert it, or to null to delete it. Omit the field to preserve existing metadata. betas: Optional header to specify the beta version(s) you want to use. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rXrYrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rbWork.update..rdrerfrgrhrvribodyrkrl) rnrrror r_postrrr'WorkUpdateParamsr#r* r=rMrOrvrFrGrHrIrJs &&$$$$$$$r6update Work.updatewsH\]k\nop pUV]U`ab b  $'*hhu5Le5LOjNk/l&m"  ""  *+F`=K^K^\^` zz L-  !*h!79K9\9\](+Q['  r9limitpagec<V^8dQhRRRRRRRRR R R R R RRRRR/ #)r1rOrNr int | OmitrOptional[str] | OmitrFrPrGrQrHrRrIrSrJrTr2z"SyncPageCursor[BetaSelfHostedWork]r4)r5s"r6r7r8soC C C  C # C / C &C "C  C 9C  ,C r9c V'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ /4CT;'g/CpRR/T;'g/CpVP \RVR7\\,\VVVV\RVR V/\P4R 7\R 7#)  Note: these endpoints are called automatically by the pre-built environment worker provided in the SDKs and CLI, for orchestrating sessions with self-hosted sandbox environments. They are included here as a reference; you do not need to invoke them directly. List work items in an environment. Args: limit: Maximum number of work items to return page: Opaque cursor from previous response for pagination betas: Optional header to specify the beta version(s) you want to use. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rXrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rbWork.list..rdrerf0/v1/environments/{environment_id}/work?beta=truerOrrrGrHrIrJqueryrrkmodel)rnrrror r _get_api_listrr r*r#rr$WorkListParams r=rOrrrFrGrHrIrJs &&$$$$$$$r6list Work.listsJ\]k\nop p  $'*hhu5Le5LOjNk/l&m"  ""  *+F`=K^K^\^` !! L]k l 23(+'%%%33  %!"  r9c8V^8dQhRRRRRRRRRR R R R R RR/#rLr4)r5s"r6r7r8Z: : :  : / : &: ":  : 9:  : r9c  V'g\RV: 24hV'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ /4CT;'g/CpRR/T;'g/CpVP \RVVR7\WEWgR 7\R 7#)  Note: these endpoints are called automatically by the pre-built environment worker provided in the SDKs and CLI, for orchestrating sessions with self-hosted sandbox environments. They are included here as a reference; you do not need to invoke them directly. Acknowledge receipt of a work item, transitioning it from 'queued' to 'starting' and removing it from the queue. Args: betas: Optional header to specify the beta version(s) you want to use. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rXrYrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rbWork.ack..$rdrerf>/v1/environments/{environment_id}/work/{work_id}/ack?beta=truerhrirj rnrrror rr~rr#r*rqs&&$$$$$$r6ackWork.acksB\]k\nop pUV]U`ab b  $'*hhu5Le5LOjNk/l&m"  ""  *+F`=K^K^\^` zz P-  )+Q['  r9desired_ttl_secondsexpected_last_heartbeatc@V^8dQhRRRRRRRRRR R R R R RRRRRR/ #r1rMrNrOrOptional[int] | OmitrrrFrPrGrQrHrRrIrSrJrTr2r,r4)r5s"r6r7r88zL L L  L 2 L "6 L /L &L "L  L 9L  -L r9c V'g\RV: 24hV'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ /4CT;'g/CpRR/T;'g/CpVP \RVVR7\VVVV \R VR V/\P4R 7\R 7#)  Note: these endpoints are called automatically by the pre-built environment worker provided in the SDKs and CLI, for orchestrating sessions with self-hosted sandbox environments. They are included here as a reference; you do not need to invoke them directly. Record a heartbeat for a work item to maintain the lease. Args: desired_ttl_seconds: Desired TTL in seconds expected_last_heartbeat: Expected last_heartbeat for conditional update (optimistic concurrency). Use literal 'NO_HEARTBEAT' to claim an unclaimed lease (first heartbeat). For subsequent heartbeats, echo the server's previous last_heartbeat value exactly. Returns 412 Precondition Failed if the actual value doesn't match. betas: Optional header to specify the beta version(s) you want to use. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rXrYrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rb!Work.heartbeat..hrdrerfD/v1/environments/{environment_id}/work/{work_id}/heartbeat?beta=truerhrrrrj) rnrrror rr~rr#rr(WorkHeartbeatParamsr, r=rMrOrrrFrGrHrIrJs &&$$$$$$$$r6 heartbeatWork.heartbeat8sR\]k\nop pUV]U`ab b  $'*hhu5Le5LOjNk/l&m"  ""  *+F`=K^K^\^` zz V-  )+'%%-/B13J*==  8'  r9block_msreclaim_older_than_msanthropic_worker_idc@V^8dQhRRRRRRRRRR R R R R RRRRRR/ #r1rOrNrrrrFrPrz str | OmitrGrQrHrRrIrSrJrTr2zOptional[BetaSelfHostedWork]r4)r5s"r6r7r8zJ J J ' J 4 J / J (J &J "J  J 9J  &J r9c V'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ RV/4CT;'g/CpRR/T;'g/CpVP \RVR7\VVVV \R VR V/\P4R 7\R 7#) F Note: these endpoints are called automatically by the pre-built environment worker provided in the SDKs and CLI, for orchestrating sessions with self-hosted sandbox environments. They are included here as a reference; you do not need to invoke them directly. Long poll for work items in the queue. Args: block_ms: How long to wait for work to arrive before returning. Must be 1-999 in milliseconds. Defaults to non-blocking (returns immediately if no work is available). reclaim_older_than_ms: Reclaim unacknowledged work items older than this many milliseconds. If omitted, uses the default (5000ms). betas: Optional header to specify the beta version(s) you want to use. anthropic_worker_id: Unique identifier for the specific worker polling, used to track aggregated environment-level work metrics in Console extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rXrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rbWork.poll..rdrerfAnthropic-Worker-ID5/v1/environments/{environment_id}/work/poll?beta=truerrrrrj) rnrrror rrprr#rr%WorkPollParamsr* r=rOrrrFrrGrHrIrJs &&$$$$$$$$r6poll Work.pollsX\]k\nop p  $'*hhu5Le5LOjNk/l&m")+>   ""  *+F`=K^K^\^` yy Qbp q(+'%%"H/1F%33  '  r9c4V^8dQhRRRRRRRRR R R R R R/#r1rOrNrFrPrGrQrHrRrIrSrJrTr2r+r4)r5s"r6r7r8P- - - / - &- "-  - 9-  &- r9c  RV'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ /4CT;'g/CpRR/T;'g/CpVP \RVR7\W4WVR7\R 7#) } Get statistics about the work queue for an environment. Args: betas: Optional header to specify the beta version(s) you want to use. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rXrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rbWork.stats..rdrerf6/v1/environments/{environment_id}/work/stats?beta=truerrirj rnrrror rrprr#r+r=rOrFrGrHrIrJs&&$$$$$r6stats Work.statss4\]k\nop p  $'*hhu5Le5LOjNk/l&m"  ""  *+F`=K^K^\^` yy Rcq r(+Q[1   r9forcec<V^8dQhRRRRRRRRRR R R R R RRRR/ #r1rMrNrOrz bool | OmitrFrPrGrQrHrRrIrSrJrTr2r*r4)r5s"r6r7r8d= = =  =  = / = &= "=  = 9=  = r9c  V'g\RV: 24hV'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ /4CT;'g/CpRR/T;'g/CpVP \RVVR7\R V/\P4\WVWxR 7\R 7#)  Note: these endpoints are called automatically by the pre-built environment worker provided in the SDKs and CLI, for orchestrating sessions with self-hosted sandbox environments. They are included here as a reference; you do not need to invoke them directly. Stop a work item, initiating graceful or forced shutdown. Args: force: If true, immediately stop work without graceful shutdown betas: Optional header to specify the beta version(s) you want to use. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rXrYrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rbWork.stop..+rdrerf?/v1/environments/{environment_id}/work/{work_id}/stop?beta=truerhrrir|) rnrrror rr~rrr&WorkStopParamsr#r* r=rMrOrrFrGrHrIrJs &&$$$$$$$r6stop Work.stopsF\]k\nop pUV]U`ab b  $'*hhu5Le5LOjNk/l&m"  ""  *+F`=K^K^\^` zz Q-  !'5!13C3R3RS(+Q['  r9r4)__name__ __module__ __qualname____firstlineno__rr>rDrrrrrrrrrrr__static_attributes__r4r9r6r-r-(s]))//9 26 9 )-9 %)9 #'9  26 > )-> %)> #'>  @C ! C &* C 26 C )-C %)C #'C AsyncWork.with_raw_responseBs(--r9cV^8dQhRR/#)r1r2AsyncWorkWithStreamingResponser4)r5s"r6r7rMs44)G4r9c \V4#rC)rr<s&r6rD!AsyncWork.with_streaming_responseLs.d33r9rFrGNrHrIrJc8V^8dQhRRRRRRRRRR R R R R RR/#rLr4)r5s"r6r7rUrUr9c "V'g\RV: 24hV'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ /4CT;'g/CpRR/T;'g/CpVP \RVVR7\WEWgR 7\R 7GR jxL #L5i) rWrXrYrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rb%AsyncWork.retrieve..|rdrerfrgrhrirjNrmrqs&&$$$$$$r6rrAsyncWork.retrieveUs@\]k\nop pUV]U`ab b  $'*hhu5Le5LOjNk/l&m"  ""  *+F`=K^K^\^` YY L-  )+Q['    #C AC C 6C C C c<V^8dQhRRRRRRRRRR R R R R RRRR/ #rur4)r5s"r6r7rrwr9c "V'g\RV: 24hV'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ /4CT;'g/CpRR/T;'g/CpTP \RVVR7\R V/\P4GR jxL \WVWxR 7\R 7GR jxL #L"L5i) ryrXrYrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rb#AsyncWork.update..rdrerfrgrhrvNrir|) rnrrror rr~rrr'rr#r*rs &&$$$$$$$r6rAsyncWork.updatesH\]k\nop pUV]U`ab b  $'*hhu5Le5LOjNk/l&m"  ""  *+F`=K^K^\^` ZZ L-  -j(-CEWEhEhii(+Q['   j  5C2AC2C2;C2 C. C2)C0*C20C2rrc<V^8dQhRRRRRRRRR R R R R RRRRR/ #)r1rOrNrrrrrFrPrGrQrHrRrIrSrJrTr2zGAsyncPaginator[BetaSelfHostedWork, AsyncPageCursor[BetaSelfHostedWork]]r4)r5s"r6r7rspC C C  C # C / C &C "C  C 9C  QC r9c V'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ /4CT;'g/CpRR/T;'g/CpVP \RVR7\\,\VVVV\RVR V/\P4R 7\R 7#) rrXrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rb!AsyncWork.list..rdrerfrrrrrr)rnrrror rrrr!r*r#rr$rrs &&$$$$$$$r6rAsyncWork.listsJ\]k\nop p  $'*hhu5Le5LOjNk/l&m"  ""  *+F`=K^K^\^` !! L]k l !34(+'%%%33  %!"  r9c8V^8dQhRRRRRRRRRR R R R R RR/#rLr4)r5s"r6r7rrr9c "V'g\RV: 24hV'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ /4CT;'g/CpRR/T;'g/CpVP \RVVR7\WEWgR 7\R 7GR jxL #L5i) rrXrYrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rb AsyncWork.ack..=rdrerfrrhrirjNrrqs&&$$$$$$r6r AsyncWork.acksB\]k\nop pUV]U`ab b  $'*hhu5Le5LOjNk/l&m"  ""  *+F`=K^K^\^` ZZ P-  )+Q['    rrrc@V^8dQhRRRRRRRRRR R R R R RRRRRR/ #rr4)r5s"r6r7rQrr9c "V'g\RV: 24hV'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ /4CT;'g/CpRR/T;'g/CpTP \RVVR7\TTTT \R VR V/\P4GR jxL R 7\R 7GR jxL #LL5i)rrXrYrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rb&AsyncWork.heartbeat..rdrerfrrhrrNrrj) rnrrror rr~rr#rr(rr,rs &&$$$$$$$$r6rAsyncWork.heartbeatQs&R\]k\nop pUV]U`ab b  $'*hhu5Le5LOjNk/l&m"  ""  *+F`=K^K^\^` ZZ V-  )+'%1-/B13J*==  8'     s6C6AC6C6AC6C2C6-C4.C64C6rrrc@V^8dQhRRRRRRRRRR R R R R RRRRRR/ #rr4)r5s"r6r7rrr9c "V'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ RV/4CT;'g/CpRR/T;'g/CpTP \RVR7\TTTT \R VR V/\P4GR jxL R 7\R 7GR jxL #LL5i)rrXrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rb!AsyncWork.poll..rdrerfrrrrrNrrj) rnrrror rrprr#rr%rr*rs &&$$$$$$$$r6rAsyncWork.polls X\]k\nop p  $'*hhu5Le5LOjNk/l&m")+>   ""  *+F`=K^K^\^` YY Qbp q(+'%1"H/1F%33  '    s1A(C +C ;AC CC CC C c4V^8dQhRRRRRRRRR R R R R R/#rr4)r5s"r6r7rrr9c n"V'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ /4CT;'g/CpRR/T;'g/CpVP \RVR7\W4WVR7\R 7GR jxL #L5i) rrXrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rb"AsyncWork.stats.. rdrerfrrrirjNrrs&&$$$$$r6rAsyncWork.statss4\]k\nop p  $'*hhu5Le5LOjNk/l&m"  ""  *+F`=K^K^\^` YY Rcq r(+Q[1     sA&B5)B595B5.B3/B5rc<V^8dQhRRRRRRRRRR R R R R RRRR/ #rr4)r5s"r6r7rrr9c "V'g\RV: 24hV'g\RV: 24h/\R\V4'd$RP\ RV4R.44M\ /4CT;'g/CpRR/T;'g/CpTP \RVVR7\R V/\P4GR jxL \WVWxR 7\R 7GR jxL #L"L5i) rrXrYrZr[c38"TFp\V4xK R#5ir]r^r_s& r6rb!AsyncWork.stop..DrdrerfrrhrNrir|) rnrrror rr~rrr&rr#r*rs &&$$$$$$$r6rAsyncWork.stopsF\]k\nop pUV]U`ab b  $'*hhu5Le5LOjNk/l&m"  ""  *+F`=K^K^\^` ZZ Q-  -gu-=?O?^?^__(+Q['   `  r worker_iddrainF auto_stopTc<V^8dQhRRRRRRRRRR R R R R R RRR/ #)r1rOrNenvironment_keyr str | Nonerzint | None | NotGivenrz int | NonerboolrrGrQr2z!AsyncIterator[BetaSelfHostedWork]r4)r5s"r6r7rYsqM M M  M  M ( M  *M M M &M  +M r9c  ^RIHp ^RIHp Hp \ V4'gT pV !\ RVP4VRR7p V !V PPPVVVVVVVR7#)uAsync-iterate work items claimed from a self-hosted environment. Each yielded item has been ack'd. The environment key authenticates the poll, ack, and stop calls via a scoped sub-client (built once per call). Async only — available on :class:`~anthropic.AsyncAnthropic` (the sync client does not expose ``poller``). With the defaults this loops forever and calls ``stop`` after the consuming ``async for`` body returns or raises (long-running runner shape). Pass ``drain=True, auto_stop=False`` to drain whatever is queued and return without owning the stop call (webhook-dispatch shape — each item is handed off to another process that calls ``stop`` when done). Args: environment_id: The self-hosted environment to claim work from. environment_key: The environment key — used as the Bearer credential on the scoped sub-client that issues poll / ack / stop requests. worker_id: Optional identifier sent on each poll. Defaults to a unique, hostname-prefixed id. block_ms: How long the server should hold an empty poll open before returning (long-poll). Server caps this at 999. Defaults to ``POLL_BLOCK_MS`` (999) when not given. Pass ``None`` to omit for a non-blocking poll — the server rejects ``0``. reclaim_older_than_ms: Reclaim un-ack'd work older than this many ms. Forwarded to the underlying poll request. drain: When True, return after the first empty poll instead of sleeping and re-polling. auto_stop: When True (default), call ``stop`` after the consumer's loop body completes. Set False when handing items off to another process that owns the stop call. extra_headers: Optional headers passed through per request on the poll / ack / stop calls. They are threaded into each call's ``extra_headers=`` and never assigned onto the client, so client state is not mutated. Auth and ``x-stainless-helper`` are supplied by the scoped sub-client built here (and the parent client's ``default_headers`` propagate via its ``client.copy()``); a header given here overrides the scoped client's same-named default for that request, so use it for caller passthrough (e.g. trace ids), not to set auth. )_copy_client_with_bearer_auth) POLL_BLOCK_MS aiter_workr zenvironments-work-poller) auth_tokenhelper)rOrrrrrrG) lib._scoped_clientrlib.environments._pollerrrrr_clientbeta environmentswork) r=rOrrrrrrrGrrrscopeds &$$$$$$$$ r6pollerAsyncWork.pollerYsrr IJ!!$H. !4<< 0&-   KK $ $ ) ))"7'  r9rOrtoolsworkdirunrestricted_pathsmax_idlec<V^8dQhRRRRRRRRRR R R R RR RRR/ #)r1rOrrr(zEnvironmentWorkerTools | Noner)zstr | os.PathLike[str] | Noner*rr+zfloat | None | NotGivenrrGrQr2r r4)r5s"r6r7rsqL L #L $ L - L / L !L *L L &L  L r9c  ^RIHp ^RIHp \ V4'gT pV !\ RVP 4VVVVVVVVR7 #)u Build an :class:`~anthropic.lib.environments.EnvironmentWorker` bound to this async client. The full worker: it polls the environment for work, and for each claimed session sets up the workdir + downloads the session agent's skills, runs the given ``tools`` against the session's tool-call events while heartbeating the work-item lease, force-stops the work on exit, and loops. Composed from this resource's :meth:`poller` and the per-session session tool runner. ``EnvironmentWorker`` is async only — its ``run`` / ``handle_item`` coroutines need an event loop. With this :class:`~anthropic.AsyncAnthropic` client the returned worker is ready to ``await worker.run()`` (long-running poll loop) or ``await worker.handle_item()`` (single already-claimed work item). It can also be constructed directly: ``EnvironmentWorker(client, ...)``. Args: environment_id: The self-hosted environment to poll for work. Required by ``EnvironmentWorker.run``; not used by ``EnvironmentWorker.handle_item``. environment_key: The environment key — the worker's single credential, used as Bearer auth on the control-plane and session-level calls. tools: Tools to expose to each claimed session. Either a fixed list or a factory invoked once per session with that session's ``AgentToolContext``. Defaults to ``beta_agent_toolset_20260401(env)``. workdir: Base directory for the per-session ``AgentToolContext``. Defaults to ``os.getcwd()`` captured when the worker is constructed (TS parity: ``process.cwd()`` at construction). unrestricted_paths: Forwarded to the per-session ``AgentToolContext``. max_idle: Seconds to keep running after the session goes idle with ``stop_reason`` ``end_turn``. Defaults to ``DEFAULT_MAX_IDLE`` (60s) when not given. ``None`` disables it. worker_id: Optional identifier sent on each poll. Defaults to a unique, hostname-prefixed id. extra_headers: Optional headers passed through per request on every call the worker makes (poll / ack / stop / heartbeat and the session tool runner's event stream / list / send). They are threaded into each call's ``extra_headers=`` and never assigned onto the client, so client state is not mutated. Auth and ``x-stainless-helper`` are supplied by the worker's scoped sub-clients (and the parent client's ``default_headers`` propagate via their ``client.copy()``); a header given here overrides a scoped client's same-named default for that request, so use it for caller passthrough (e.g. trace ids), not to set auth. )r )DEFAULT_MAX_IDLEr )rOrr(r)r*r+rrG)lib.environments._workerr lib.tools._beta_session_runnerr.rrr!) r=rOrr(r)r*r+rrGr r.s &$$$$$$$$ r6workerAsyncWork.workersPx CG!!'H !4<< 0)+1'  r9r4)rrrrrr>rDrrrrrrrrrrrr&r1rr4r9r6r.r.As..449 26 9 )-9 %)9 #'9  26 > )-> %)> #'>  @C ! C &* C 26 C )-C %)C #'C > KK  %<< II  $;; HH *AA NN %<< II  &== JJ  %<< II  r9 r:rrrrrrrrrNrrrrr=rr4r9r6r3r3   r9r3c"]tRtRtRRltRtR#)ric V^8dQhRRRR/#r1r$r.r2r6r4)r5s"r6r7%AsyncWorkWithRawResponse.__annotate__  Y 4 r9c bWn\P!VP4Vn\P!VP4Vn\P!VP 4Vn\P!VP 4Vn\P!VP4Vn\P!VP4Vn\P!VP4Vn \P!VP4Vn R#r]) r:rasync_to_raw_response_wrapperrrrrrrrrrr<s&&r6r=!AsyncWorkWithRawResponse.__init__s (FF MM  'DD KK  %BB II  $AA HH *GG NN %BB II  &CC JJ  %BB II  r9r?Nr@r4r9r6rrrAr9rc"]tRtRtRRltRtR#)rAi3c V^8dQhRRRR/#r5r4)r5s"r6r7&WorkWithStreamingResponse.__annotate__4r8r9c Wn\VP4Vn\VP4Vn\VP4Vn\VP 4Vn\VP 4Vn\VP4Vn\VP4Vn\VP4Vn R#r]) r:rrrrrrrrrrr<s&&r6r="WorkWithStreamingResponse.__init__4s 4 MM  3 KK  1 II  0 HH 6 NN 1 II  2 JJ  1 II  r9r?Nr@r4r9r6rArA3rAr9rAc"]tRtRtRRltRtR#)riQc V^8dQhRRRR/#rDr4)r5s"r6r7+AsyncWorkWithStreamingResponse.__annotate__RrFr9c Wn\VP4Vn\VP4Vn\VP4Vn\VP 4Vn\VP 4Vn\VP4Vn\VP4Vn\VP4Vn R#r]) r:rrrrrrrrrrr<s&&r6r='AsyncWorkWithStreamingResponse.__init__Rs : MM  9 KK  7 II  6 HH < NN 7 II  8 JJ  7 II  r9r?Nr@r4r9r6rrQrAr9r)F __future__rostypingrrrrr itertoolsr httpxcollections.abcr r!r r/r r r_typesrrrrrrr_utilsrrrrr_compatr _resourcerr _responserr paginationr r! _base_clientr"r#types.beta.environmentsr$r%r&r'r(types.anthropic_beta_paramr)-types.beta.environments.beta_self_hosted_workr*9types.beta.environments.beta_self_hosted_work_queue_statsr+@types.beta.environments.beta_self_hosted_work_heartbeat_responser,__all__r-r.r3rrArr4r9r6rhs# << -*V!LLLgg';Z:A>Pft ; V ?V rs   s  l  <  <  <  r9