"j]SSKJr SSKrSSKJrJrJrJrJrJ r SSK J r SSK J r SSKr\(aSSKJr SSKJr SS KJr SS KJrJr SS KJrJrJrJrJrJrJr SS K J!r!J"r"J#r# SS K$J%r% SSK&J'r'J(r( SSK)J*r*J+r+J,r,J-r- SSK.J/r/J0r0 SSK1J2r2J3r3 SSK4J5r5J6r6 SSK7J8r8 SSK9J:r: SSK;Jr> SS/r?"SS\'5r@"SS\(5rA"SS5rB"SS5rC"SS 5rD"S!S"5rEg)#) annotationsN) TYPE_CHECKINGDictListOptionalcastoverload)chain) deprecated) AsyncIterator)AsyncAnthropic)MemoryDeleteMode)EnvironmentWorkerEnvironmentWorkerTools)BodyOmitQueryHeadersNotGivenomit not_given)is_given path_templatestrip_not_given)cached_property)SyncAPIResourceAsyncAPIResource)to_raw_response_wrapperto_streamed_response_wrapperasync_to_raw_response_wrapper"async_to_streamed_response_wrapper)SyncPageCursorAsyncPageCursor)AsyncPaginatormake_request_options)UNRESTRICTED_PATHS_DEPRECATIONreject_unrestricted_paths)AnthropicBetaParam)BetaSelfHostedWork)BetaSelfHostedWorkQueueStats)#BetaSelfHostedWorkHeartbeatResponseWork AsyncWorkc <\rSrSr\SSj5r\SSj5r\\SSS\S.SSjjr \\SSS\S.SSjjr \\\SSS\S.SS jjr \SSS\S .SS jjr \\\SSS\S .SS jjr \\\\SSS\S.SSjjr\\SSS\S.SSjjr\\\SSS\S.SSjjrSrg)r-&c[U5$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 )WorkWithRawResponseselfs g/home/mande/repo/quber/.venv/lib/python3.13/site-packages/anthropic/resources/beta/environments/work.pywith_raw_responseWork.with_raw_response's#4((c[U5$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 )WorkWithStreamingResponser4s r6with_streaming_responseWork.with_streaming_response1s)..r9Nbetas workspace_id extra_headers extra_query extra_bodytimeoutc hU(d[SU<35eU(d[SU<35e0[[U5(a#SR[ SU5S/55O[ US.5EU=(d 0EnSS0U=(d 0EnUR [SUUS 9[XVXxS 9[S 9$)  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. workspace_id: Optional header to select the Workspace for this request. The value is a Workspace ID (for example, `wrkspc_011CZkZaBF1tNoB5wlCeusgy`). Only needed for credentials that can act on more than one Workspace. A credential that belongs to a specific Workspace may omit it; if sent, it must match that Workspace. 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 ,c38# UHn[U5v M g7fNstr.0es r6 Work.retrieve..i5Lec!ffemanaged-agents-2026-04-01anthropic-betazanthropic-workspace-idrX:/v1/environments/{environment_id}/work/{work_id}?beta=trueenvironment_idwork_idrBrCrDrEoptionscast_to ValueErrorrrjoinr r_getrr&r* r5r\r[r@rArBrCrDrEs r6retrieve Work.retrieve:sP\]k\nop pUV]U`ab b   '*hhu5Le5LOjNk/l&m".:   "  *+F`=K^\^` yy L-  )+Q['  r9c nU(d[SU<35eU(d[SU<35e0[[U5(a#SR[ SU5S/55O[ US.5EU=(d 0EnSS0U=(d 0EnUR [SUUS 9S U0[XgXS 9[S 9$) d 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. workspace_id: Optional header to select the Workspace for this request. The value is a Workspace ID (for example, `wrkspc_011CZkZaBF1tNoB5wlCeusgy`). Only needed for credentials that can act on more than one Workspace. A credential that belongs to a specific Workspace may omit it; if sent, it must match that Workspace. 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 rHrIrJc38# UHn[U5v M g7frLrMrOs r6rRWork.update..rTrUrVrWrXrYrZmetadatar]bodyr_r` rbrrrcr r_postrr&r* r5r\r[rlr@rArBrCrDrEs r6update Work.update~sX\]k\nop pUV]U`ab b   '*hhu5Le5LOjNk/l&m".:   "  *+F`=K^\^` zz L-  h'(+Q['  r9limitpager@rBrCrDrEc \U(d[SU<35e0[S[U5(a#SR[ SU5S/55O[ 05EU=(d 0EnSS0U=(d 0EnUR [SUS9[[[UUUUUUS.S 9[S 9$)  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 rHrXrJc38# UHn[U5v M g7frLrMrOs r6rRWork.list..rTrUrV0/v1/environments/{environment_id}/work?beta=truer[rurvrBrCrDrEqueryrvr_model) rbrrrcr r _get_api_listrr#r*r& r5r[rurvr@rBrCrDrEs r6list Work.listsJ\]k\nop p  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` !! L]k l 23(+'%"  %"  r9r@rBrCrDrEc fU(d[SU<35eU(d[SU<35e0[S[U5(a#SR[ SU5S/55O[ 05EU=(d 0EnSS0U=(d 0EnUR [SUUS9[XEXgS 9[S 9$)  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 rHrIrXrJc38# UHn[U5v M g7frLrMrOs r6rRWork.ack..1rTrUrV>/v1/environments/{environment_id}/work/{work_id}/ack?beta=truerZr]r^ror5r\r[r@rBrCrDrEs r6ackWork.ack sB\]k\nop pUV]U`ab b  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` zz P-  )+Q['  r9desired_ttl_secondsexpected_last_heartbeatr@rBrCrDrEc rU(d[SU<35eU(d[SU<35e0[S[U5(a#SR[ SU5S/55O[ 05EU=(d 0EnSS0U=(d 0EnUR [SUUS9[UUUU UUS .S 9[S 9$)  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 rHrIrXrJc38# UHn[U5v M g7frLrMrOs r6rR!Work.heartbeat..urTrUrVD/v1/environments/{environment_id}/work/{work_id}/heartbeat?beta=truerZrrr~r^ rbrrrcr rrprr&r, r5r\r[rrr@rBrCrDrEs r6 heartbeatWork.heartbeatEsR\]k\nop pUV]U`ab b  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` zz V-  )+'%+>/F 8!  r9block_msreclaim_older_than_msr@anthropic_worker_idrBrCrDrEc FU(d[SU<35e0[[U5(a#SR[ SU5S/55O[ US.5EU=(d 0EnSS0U=(d 0EnUR [SUS9[UUUU UUS .S 9[S 9$) 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 rHrJc38# UHn[U5v M g7frLrMrOs r6rRWork.poll..rTrUrVrXzAnthropic-Worker-IDrX5/v1/environments/{environment_id}/work/poll?beta=truer|rrr~r^ra r5r[rrr@rrBrCrDrEs r6poll Work.pollsX\]k\nop p   '*hhu5Le5LOjNk/l&m"+>   "  *+F`=K^\^` yy Qbp q(+'% (-B '  r9c :U(d[SU<35e0[[U5(a#SR[ SU5S/55O[ US.5EU=(d 0EnSS0U=(d 0EnUR [SUS9[XEXgS 9[S 9$)  Get statistics about the work queue for an environment. Args: betas: Optional header to specify the beta version(s) you want to use. workspace_id: Optional header to select the Workspace for this request. The value is a Workspace ID (for example, `wrkspc_011CZkZaBF1tNoB5wlCeusgy`). Only needed for credentials that can act on more than one Workspace. A credential that belongs to a specific Workspace may omit it; if sent, it must match that Workspace. 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 rHrJc38# UHn[U5v M g7frLrMrOs r6rRWork.stats..rTrUrVrWrX6/v1/environments/{environment_id}/work/stats?beta=truer|r]r^ rbrrrcr rrdrr&r+r5r[r@rArBrCrDrEs r6stats Work.statssD\]k\nop p   '*hhu5Le5LOjNk/l&m".:   "  *+F`=K^\^` yy Rcq r(+Q[1   r9forcer@rArBrCrDrEc nU(d[SU<35eU(d[SU<35e0[[U5(a#SR[ SU5S/55O[ US.5EU=(d 0EnSS0U=(d 0EnUR [SUUS 9S U0[XgXS 9[S 9$) # 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. workspace_id: Optional header to select the Workspace for this request. The value is a Workspace ID (for example, `wrkspc_011CZkZaBF1tNoB5wlCeusgy`). Only needed for credentials that can act on more than one Workspace. A credential that belongs to a specific Workspace may omit it; if sent, it must match that Workspace. 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 rHrIrJc38# UHn[U5v M g7frLrMrOs r6rRWork.stop..CrTrUrVrWrX?/v1/environments/{environment_id}/work/{work_id}/stop?beta=truerZrr]rmro r5r\r[rr@rArBrCrDrEs r6stop Work.stopsV\]k\nop pUV]U`ab b   '*hhu5Le5LOjNk/l&m".:   "  *+F`=K^\^` zz Q-  5!(+Q['  r9)returnr3)rr<r\rNr[rNr@List[AnthropicBetaParam] | OmitrA str | OmitrBHeaders | NonerC Query | NonerD Body | NonerE(float | httpx2.Timeout | None | NotGivenrr*r\rNr[rNrlzDict[str, Optional[str]]r@rrArrBrrCrrDrrErrr*)r[rNru int | OmitrvOptional[str] | Omitr@rrBrrCrrDrrErrz"SyncPageCursor[BetaSelfHostedWork]r\rNr[rNr@rrBrrCrrDrrErrr*r\rNr[rNrOptional[int] | Omitrrr@rrBrrCrrDrrErrr,r[rNrrrrr@rrrrBrrCrrDrrErrzOptional[BetaSelfHostedWork]r[rNr@rrArrBrrCrrDrrErrr+r\rNr[rNrz bool | Omitr@rrArrBrrCrrDrrErrr*)__name__ __module__ __qualname____firstlineno__rr7r=rrrfrrrrrrrr__static_attributes__rr9r6r-r-&s-))//26#')-$("&.rTrUrVrWrXrYrZr]r^Nrares r6rfAsyncWork.retrievensP\]k\nop pUV]U`ab b   '*hhu5Le5LOjNk/l&m".:   "  *+F`=K^\^` YY L-  )+Q['    sB7C9B>:Cc # U(d[SU<35eU(d[SU<35e0[[U5(a#SR[ SU5S/55O[ US.5EU=(d 0EnSS0U=(d 0EnUR [SUUS 9S U0[XgXS 9[S 9IS hvN $N7f)rirHrIrJc38# UHn[U5v M g7frLrMrOs r6rR#AsyncWork.update..rTrUrVrWrXrYrZrlr]rmNrorqs r6rrAsyncWork.updatesX\]k\nop pUV]U`ab b   '*hhu5Le5LOjNk/l&m".:   "  *+F`=K^\^` ZZ L-  h'(+Q['    B:C<C=Crtc \U(d[SU<35e0[S[U5(a#SR[ SU5S/55O[ 05EU=(d 0EnSS0U=(d 0EnUR [SUS9[[[UUUUUUS.S 9[S 9$) rxrHrXrJc38# UHn[U5v M g7frLrMrOs r6rR!AsyncWork.list..%rTrUrVr{r|r}r~r) rbrrrcr rrrr$r*r&rs r6rAsyncWork.listsJ\]k\nop p  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` !! L]k l !34(+'%"  %"  r9rc # U(d[SU<35eU(d[SU<35e0[S[U5(a#SR[ SU5S/55O[ 05EU=(d 0EnSS0U=(d 0EnUR [SUUS9[XEXgS 9[S 9IS hvN $N7f) rrHrIrXrJc38# UHn[U5v M g7frLrMrOs r6rR AsyncWork.ack..erTrUrVrrZr]r^Nrors r6r AsyncWork.ack=sB\]k\nop pUV]U`ab b  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` ZZ P-  )+Q['    sB6B?8B=9B?rc # U(d[SU<35eU(d[SU<35e0[S[U5(a#SR[ SU5S/55O[ 05EU=(d 0EnSS0U=(d 0EnUR [SUUS9[UUUU UUS .S 9[S 9IS hvN $N7f) rrHrIrXrJc38# UHn[U5v M g7frLrMrOs r6rR&AsyncWork.heartbeat..rTrUrVrrZrr~r^Nrrs r6rAsyncWork.heartbeatysR\]k\nop pUV]U`ab b  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` ZZ V-  )+'%+>/F 8!     sBC?Crc b# U(d[SU<35e0[[U5(a#SR[ SU5S/55O[ US.5EU=(d 0EnSS0U=(d 0EnUR [SUS9[UUUU UUS .S 9[S 9IS hvN $N7f) rrHrJc38# UHn[U5v M g7frLrMrOs r6rR!AsyncWork.poll..rTrUrVrrXrr|rr~r^Nrars r6rAsyncWork.pollsX\]k\nop p   '*hhu5Le5LOjNk/l&m"+>   "  *+F`=K^\^` YY Qbp q(+'% (-B '    sB&B/(B-)B/c V# U(d[SU<35e0[[U5(a#SR[ SU5S/55O[ US.5EU=(d 0EnSS0U=(d 0EnUR [SUS9[XEXgS 9[S 9IS hvN $N7f) rrHrJc38# UHn[U5v M g7frLrMrOs r6rR"AsyncWork.stats..4rTrUrVrWrXrr|r]r^Nrrs r6rAsyncWork.stats sD\]k\nop p   '*hhu5Le5LOjNk/l&m".:   "  *+F`=K^\^` YY Rcq r(+Q[1     sB B)"B'#B)rc # U(d[SU<35eU(d[SU<35e0[[U5(a#SR[ SU5S/55O[ US.5EU=(d 0EnSS0U=(d 0EnUR [SUUS 9S U0[XgXS 9[S 9IS hvN $N7f)rrHrIrJc38# UHn[U5v M g7frLrMrOs r6rR!AsyncWork.stop..wrTrUrVrWrXrrZrr]rmNrors r6rAsyncWork.stopEsV\]k\nop pUV]U`ab b   '*hhu5Le5LOjNk/l&m".:   "  *+F`=K^\^` ZZ Q-  5!(+Q['    rFT) worker_idrrdrain auto_stoprBc SSKJn SSKJn Jn [ U5(dU nU "[ SUR5USS9n U "U RRRUUUUUUUS9$)usAsync-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 `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. r )_copy_client_with_bearer_auth) POLL_BLOCK_MS aiter_workrzenvironments-work-poller) auth_tokenhelper)r[rrrrrrB) lib._scoped_clientrlib.environments._pollerrrrr_clientbeta environmentswork) r5r[environment_keyrrrrrrBrrrscopeds r6pollerAsyncWork.pollersrr IJ!!$H. !4<< 0&-   KK $ $ ) ))"7'  r9enabled r[r toolsworkdirmax_file_bytesmax_idlememory_sync_intervalmemory_sync_deletionsrrBc grLr) r5r[r rrrrrrrrBs r6workerAsyncWork.workers r9c grLr) r5r[r rrunrestricted_pathsrrrrrrBs r6rrs  r9) r[r rrrrrrrrrBc SSKJn Jn SSKJn [ U5 [ U5(dUn[ U5(dU nU "[SUR5UUUUUUUU U U S9 $)u[ Build an `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 `poller` and the per-session session tool runner. `EnvironmentWorker` is async only — its `run` / `handle_item` coroutines need an event loop. With this `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)`. Async tools share the event loop with the lease heartbeat, so keep them non-blocking. 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: Deprecated and no longer accepted; passing either value raises `TypeError` (see `AgentToolContext`). max_file_bytes: Forwarded to the per-session `AgentToolContext` — the size cap (bytes) for the `read`/`edit` tools. `not_given` (default) uses the built-in 256 KiB cap; a positive int sets a custom cap; `None` disables the cap. 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. memory_sync_interval: How often (seconds) to sync the session's attached memory stores; `None` disables memory. Defaults to `DEFAULT_MEMORY_SYNC_INTERVAL` (15s) when not given. memory_sync_deletions: `"enabled"` (default), `"log_only"`, or `"disabled"`. 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_MEMORY_SYNC_INTERVALr)DEFAULT_MAX_IDLErr) lib.environments._workerrrlib.tools._beta_session_runnerrr(rrr)r5r[r rrrrrrrrrBrrrs r6rrsqV aG!"45!!'H,--#?  !4<< 0)+)!5"7'  r9r)rr)rrrr)r[rNrurrvrr@rrBrrCrrDrrErrzGAsyncPaginator[BetaSelfHostedWork, AsyncPageCursor[BetaSelfHostedWork]]rrrrr)r[rNr rNr str | Nonerint | None | NotGivenrz int | Nonerboolrr#rBrrz!AsyncIterator[BetaSelfHostedWork])r[r!r r!rEnvironmentWorkerTools | Nonerstr | os.PathLike[str] | Nonerr"rfloat | None | NotGivenrr&rrrr!rBrrr)r[r!r r!rr$rr%rr#rr"rr&rr&rrrr!rBrrr)r[r!r r!rr$rr%rzbool | NotGivenrr"rr&rr&rrrr!rBrrr)rrrrrr7r=rrrfrrrrrrrrr r rr r'rrr9r6r.r.Zs..4426#')-$("&rQs" FF( -*8VLLL??'; ;Aa=Pft ; q ?q hD   D  N  <  <  <  r9