§
    ÜŽ’jtï  ã                  ó  — d dl mZ d dlZd dlmZmZmZmZmZ d dl	m
Z
 d dlZerd dlmZ ddlmZ ddlmZmZ dd	lmZ dd
lmZmZmZmZmZmZmZ ddlmZmZm Z m!Z!m"Z" ddl#m$Z$ ddl%m&Z&m'Z' ddl(m)Z)m*Z* ddl+m,Z,m-Z- ddl.m/Z/m0Z0 ddl1m2Z2m3Z3m4Z4m5Z5m6Z6 ddl7m8Z8 ddl9m:Z: ddl;m<Z< ddl=m>Z> ddgZ? G d„ de&¦  «        Z@ G d„ de'¦  «        ZA G d„ d¦  «        ZB G d„ d¦  «        ZC G d„ d¦  «        ZD G d „ d!¦  «        ZEdS )"é    )ÚannotationsN)ÚTYPE_CHECKINGÚDictÚListÚOptionalÚcast)Úchain)ÚAsyncIteratoré   )ÚAsyncAnthropic)ÚEnvironmentWorkerÚEnvironmentWorkerTools)Ú_legacy_response)ÚBodyÚOmitÚQueryÚHeadersÚNotGivenÚomitÚ	not_given)Úis_givenÚpath_templateÚmaybe_transformÚstrip_not_givenÚasync_maybe_transform)Úcached_property)ÚSyncAPIResourceÚAsyncAPIResource)Úto_streamed_response_wrapperÚ"async_to_streamed_response_wrapper)ÚSyncPageCursorÚAsyncPageCursor)ÚAsyncPaginatorÚmake_request_options)Úwork_list_paramsÚwork_poll_paramsÚwork_stop_paramsÚwork_update_paramsÚwork_heartbeat_params)ÚAnthropicBetaParam)ÚBetaSelfHostedWork)ÚBetaSelfHostedWorkQueueStats)Ú#BetaSelfHostedWorkHeartbeatResponseÚWorkÚ	AsyncWorkc            	      óþ   — e Zd Zed5d„¦   «         Zed6d„¦   «         Zedddedœd7d„Zedddedœd8d„Z	eeedddedœd9d „Z
edddedœd7d!„Zeeeddded"œd:d'„Zeeeeddded(œd;d.„Zedddedœd<d0„Zeeddded1œd=d4„ZdS )>r.   ÚreturnÚWorkWithRawResponsec                ó    — t          | ¦  «        S ©a  
        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
        )r2   ©Úselfs    úXC:\Projects\DSCons\.venv\Lib\site-packages\anthropic\resources\beta\environments\work.pyÚwith_raw_responsezWork.with_raw_response)   s   € õ # 4Ñ(Ô(Ð(ó    ÚWorkWithStreamingResponsec                ó    — t          | ¦  «        S ©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
        )r:   r5   s    r7   Úwith_streaming_responsezWork.with_streaming_response3   s   € õ )¨Ñ.Ô.Ð.r9   N©ÚbetasÚextra_headersÚextra_queryÚ
extra_bodyÚtimeoutÚwork_idÚstrÚenvironment_idr?   úList[AnthropicBetaParam] | Omitr@   úHeaders | NonerA   úQuery | NonerB   úBody | NonerC   ú'float | httpx.Timeout | None | NotGivenr+   c          
     ó�  — |st          d|›�¦  «        ‚|st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d||¬¦  «        t          ||||¬	¦  «        t          ¬
¦  «        S )áã  
        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ú,c              3  ó4   K  — | ]}t          |¦  «        V — Œd S ©N©rE   ©Ú.0Úes     r7   ú	<genexpr>z Work.retrieve.<locals>.<genexpr>c   ó(   è è € Ð5LÐ5LÀµc¸!±f´fÐ5LÐ5LÐ5LÐ5LÐ5LÐ5Lr9   úmanaged-agents-2026-04-01ú:/v1/environments/{environment_id}/work/{work_id}?beta=true©rF   rD   ©r@   rA   rB   rC   ©ÚoptionsÚcast_to©
Ú
ValueErrorr   r   Újoinr	   r   Ú_getr   r$   r+   ©r6   rD   rF   r?   r@   rA   rB   rC   s           r7   ÚretrievezWork.retrieve<   s(  € ð@ ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpØð 	cÝÐaÐV]ÐaÐaÑbÔbÐbð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ�yŠyÝØLØ-Øðñ ô õ
 )Ø+¸ÐQ[Ðelðñ ô õ 'ð ñ 

ô 

ð 
	
r9   ÚmetadataúDict[str, Optional[str]]c          
     óÆ  — |st          d|›�¦  «        ‚|st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d||¬¦  «        t          d	|it          j
        ¦  «        t          ||||¬
¦  «        t          ¬¦  «        S )áw  
        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
        rN   rO   rP   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   zWork.update.<locals>.<genexpr>¢   rY   r9   rZ   r[   r\   rg   r]   ©Úbodyr_   r`   )rb   r   r   rc   r	   r   Ú_postr   r   r(   ÚWorkUpdateParamsr$   r+   ©	r6   rD   rF   rg   r?   r@   rA   rB   rC   s	            r7   ÚupdatezWork.updatew   s>  € ðH ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpØð 	cÝÐaÐV]ÐaÐaÑbÔbÐbð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ�zŠzÝØLØ-Øðñ ô õ
 ! *¨hÐ!7Õ9KÔ9\Ñ]Ô]Ý(Ø+¸ÐQ[Ðelðñ ô õ 'ð ñ 
ô 
ð 	
r9   ©ÚlimitÚpager?   r@   rA   rB   rC   rs   ú
int | Omitrt   úOptional[str] | Omitú"SyncPageCursor[BetaSelfHostedWork]c               óÀ  — |st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d|¬¦  «        t          t                   t          ||||t          ||dœt          j        ¦  «        ¬	¦  «        t          ¬
¦  «        S )áJ  
        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
        rN   rP   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   zWork.list.<locals>.<genexpr>á   rY   r9   rZ   ú0/v1/environments/{environment_id}/work?beta=true©rF   ©rs   rt   ©r@   rA   rB   rC   Úquery©rt   r_   Úmodel)rb   r   r   rc   r	   r   Ú_get_api_listr   r!   r+   r$   r   r%   ÚWorkListParams©	r6   rF   rs   rt   r?   r@   rA   rB   rC   s	            r7   Úlistz	Work.list·   s-  € ðJ ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ×!Ò!ÝÐLÐ]kÐlÑlÔlÝÕ 2Ô3Ý(Ø+Ø'Ø%ØÝ%à!&Ø $ðð õ %Ô3ñô ðñ ô õ %ð! "ñ 
ô 
ð 	
r9   c          
     ó�  — |st          d|›�¦  «        ‚|st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d||¬¦  «        t          ||||¬	¦  «        t          ¬
¦  «        S )á"  
        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
        rN   rO   rP   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   zWork.ack.<locals>.<genexpr>$  rY   r9   rZ   ú>/v1/environments/{environment_id}/work/{work_id}/ack?beta=truer\   r]   r^   ©
rb   r   r   rc   r	   r   rn   r   r$   r+   re   s           r7   ÚackzWork.ackü   s(  € ðB ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpØð 	cÝÐaÐV]ÐaÐaÑbÔbÐbð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ�zŠzÝØPØ-Øðñ ô õ
 )Ø+¸ÐQ[Ðelðñ ô õ 'ð ñ 

ô 

ð 
	
r9   ©Údesired_ttl_secondsÚexpected_last_heartbeatr?   r@   rA   rB   rC   r�   úOptional[int] | OmitrŽ   r-   c               óÈ  — |st          d|›�¦  «        ‚|st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d||¬¦  «        t          ||||	t          ||d	œt          j        ¦  «        ¬
¦  «        t          ¬¦  «        S )á’  
        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
        rN   rO   rP   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   z!Work.heartbeat.<locals>.<genexpr>h  rY   r9   rZ   úD/v1/environments/{environment_id}/work/{work_id}/heartbeat?beta=truer\   ©r�   rŽ   r~   r^   )rb   r   r   rc   r	   r   rn   r   r$   r   r)   ÚWorkHeartbeatParamsr-   ©
r6   rD   rF   r�   rŽ   r?   r@   rA   rB   rC   s
             r7   Ú	heartbeatzWork.heartbeat8  sN  € ðR ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpØð 	cÝÐaÐV]ÐaÐaÑbÔbÐbð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ�zŠzÝØVØ-Øðñ ô õ
 )Ø+Ø'Ø%ØÝ%à/BØ3Jðð õ *Ô=ñô ðñ ô õ 8ð' ñ 
ô 
ð 	
r9   ©Úblock_msÚreclaim_older_than_msr?   Úanthropic_worker_idr@   rA   rB   rC   r™   rš   r›   ú
str | OmitúOptional[BetaSelfHostedWork]c               ó   — |st          d|›�¦  «        ‚i t          t          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          |dœ¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d|¬¦  «        t          ||||	t          ||d	œt          j        ¦  «        ¬
¦  «        t          ¬¦  «        S )áÞ  
        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
        rN   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   zWork.poll.<locals>.<genexpr>·  rY   r9   rZ   ©rP   zAnthropic-Worker-IDrP   ú5/v1/environments/{environment_id}/work/poll?beta=truer|   ©r™   rš   r~   r^   )rb   r   r   rc   r	   r   rd   r   r$   r   r&   ÚWorkPollParamsr+   ©
r6   rF   r™   rš   r?   r›   r@   rA   rB   rC   s
             r7   Úpollz	Work.poll†  s)  € ðX ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpð

Ýõ   ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"Ø+>ð	ð ñô ð

ð Ð" ð

ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ�yŠyÝÐQÐbpÐqÑqÔqÝ(Ø+Ø'Ø%ØÝ%à$,Ø1Fðð õ %Ô3ñô ðñ ô õ 'ð ñ 
ô 
ð 	
r9   r,   c          
     óf  — |st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d|¬¦  «        t          ||||¬¦  «        t          ¬	¦  «        S )
á½  
        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
        rN   rP   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   zWork.stats.<locals>.<genexpr>ñ  rY   r9   rZ   ú6/v1/environments/{environment_id}/work/stats?beta=truer|   r]   r^   ©
rb   r   r   rc   r	   r   rd   r   r$   r,   ©r6   rF   r?   r@   rA   rB   rC   s          r7   Ústatsz
Work.statsÒ  sû   € ð4 ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ�yŠyÝÐRÐcqÐrÑrÔrÝ(Ø+¸ÐQ[Ðelðñ ô õ 1ð ñ 
ô 
ð 	
r9   ©Úforcer?   r@   rA   rB   rC   r¯   úbool | Omitc          
     óÆ  — |st          d|›�¦  «        ‚|st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d||¬¦  «        t          d	|it          j
        ¦  «        t          ||||¬
¦  «        t          ¬¦  «        S )á.  
        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
        rN   rO   rP   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   zWork.stop.<locals>.<genexpr>+  rY   r9   rZ   ú?/v1/environments/{environment_id}/work/{work_id}/stop?beta=truer\   r¯   r]   rl   )rb   r   r   rc   r	   r   rn   r   r   r'   ÚWorkStopParamsr$   r+   ©	r6   rD   rF   r¯   r?   r@   rA   rB   rC   s	            r7   Ústopz	Work.stop  s>  € ðF ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpØð 	cÝÐaÐV]ÐaÐaÑbÔbÐbð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ�zŠzÝØQØ-Øðñ ô õ
 ! '¨5Ð!1Õ3CÔ3RÑSÔSÝ(Ø+¸ÐQ[Ðelðñ ô õ 'ð ñ 
ô 
ð 	
r9   )r1   r2   )r1   r:   ©rD   rE   rF   rE   r?   rG   r@   rH   rA   rI   rB   rJ   rC   rK   r1   r+   ©rD   rE   rF   rE   rg   rh   r?   rG   r@   rH   rA   rI   rB   rJ   rC   rK   r1   r+   )rF   rE   rs   ru   rt   rv   r?   rG   r@   rH   rA   rI   rB   rJ   rC   rK   r1   rw   ©rD   rE   rF   rE   r�   r�   rŽ   rv   r?   rG   r@   rH   rA   rI   rB   rJ   rC   rK   r1   r-   ©rF   rE   r™   r�   rš   r�   r?   rG   r›   rœ   r@   rH   rA   rI   rB   rJ   rC   rK   r1   r�   ©rF   rE   r?   rG   r@   rH   rA   rI   rB   rJ   rC   rK   r1   r,   ©rD   rE   rF   rE   r¯   r°   r?   rG   r@   rH   rA   rI   rB   rJ   rC   rK   r1   r+   )Ú__name__Ú
__module__Ú__qualname__r   r8   r=   r   r   rf   rq   r…   r‹   r—   r¦   r­   r·   © r9   r7   r.   r.   (   s  € € € € € Øð)ð )ð )ñ „_ð)ð ð/ð /ð /ñ „_ð/ð 26ð )-Ø$(Ø"&Ø;Dð9
ð 9
ð 9
ð 9
ð 9
ð 9
ðB 26ð )-Ø$(Ø"&Ø;Dð>
ð >
ð >
ð >
ð >
ð >
ðH !Ø%)Ø15ð )-Ø$(Ø"&Ø;DðC
ð C
ð C
ð C
ð C
ð C
ðT 26ð )-Ø$(Ø"&Ø;Dð:
ð :
ð :
ð :
ð :
ð :
ðB 59Ø8<Ø15ð )-Ø$(Ø"&Ø;DðL
ð L
ð L
ð L
ð L
ð L
ðd *.Ø6:Ø15Ø*.ð )-Ø$(Ø"&Ø;DðJ
ð J
ð J
ð J
ð J
ð J
ð` 26ð )-Ø$(Ø"&Ø;Dð-
ð -
ð -
ð -
ð -
ð -
ðh "Ø15ð )-Ø$(Ø"&Ø;Dð=
ð =
ð =
ð =
ð =
ð =
ð =
ð =
r9   c            
      ó4  — e Zd ZedMd„¦   «         ZedNd„¦   «         ZedddedœdOd„ZedddedœdPd„Z	eeedddedœdQd „Z
edddedœdOd!„Zeeeddded"œdRd'„Zeeeeddded(œdSd.„ZedddedœdTd0„Zeeddded1œdUd4„Zdedd5d6dd7œdVdA„Zddddd5eedddBœ	dWdL„ZdS )Xr/   r1   ÚAsyncWorkWithRawResponsec                ó    — t          | ¦  «        S r4   )rÃ   r5   s    r7   r8   zAsyncWork.with_raw_responseB  s   € õ (¨Ñ-Ô-Ð-r9   ÚAsyncWorkWithStreamingResponsec                ó    — t          | ¦  «        S r<   )rÅ   r5   s    r7   r=   z!AsyncWork.with_streaming_responseL  s   € õ .¨dÑ3Ô3Ð3r9   Nr>   rD   rE   rF   r?   rG   r@   rH   rA   rI   rB   rJ   rC   rK   r+   c          
   ƒ  ó   K  — |st          d|›�¦  «        ‚|st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d||¬¦  «        t          ||||¬	¦  «        t          ¬
¦  «        ƒ d{V —†S )rM   rN   rO   rP   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   z%AsyncWork.retrieve.<locals>.<genexpr>|  rY   r9   rZ   r[   r\   r]   r^   Nra   re   s           r7   rf   zAsyncWork.retrieveU  sJ  è è € ð@ ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpØð 	cÝÐaÐV]ÐaÐaÑbÔbÐbð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ—Y’YÝØLØ-Øðñ ô õ
 )Ø+¸ÐQ[Ðelðñ ô õ 'ð ñ 

ô 

ð 

ð 

ð 

ð 

ð 

ð 

ð 
	
r9   rg   rh   c          
   ƒ  óâ  K  — |st          d|›�¦  «        ‚|st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d||¬¦  «        t          d	|it          j
        ¦  «        ƒ d
{V —†t          ||||¬¦  «        t          ¬¦  «        ƒ d
{V —†S )rj   rN   rO   rP   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   z#AsyncWork.update.<locals>.<genexpr>»  rY   r9   rZ   r[   r\   rg   Nr]   rl   )rb   r   r   rc   r	   r   rn   r   r   r(   ro   r$   r+   rp   s	            r7   rq   zAsyncWork.update�  sr  è è € ðH ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpØð 	cÝÐaÐV]ÐaÐaÑbÔbÐbð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ—Z’ZÝØLØ-Øðñ ô õ
 -¨j¸(Ð-CÕEWÔEhÑiÔiÐiÐiÐiÐiÐiÐiÝ(Ø+¸ÐQ[Ðelðñ ô õ 'ð  ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ð 	
r9   rr   rs   ru   rt   rv   úGAsyncPaginator[BetaSelfHostedWork, AsyncPageCursor[BetaSelfHostedWork]]c               óÀ  — |st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d|¬¦  «        t          t                   t          ||||t          ||dœt          j        ¦  «        ¬	¦  «        t          ¬
¦  «        S )ry   rN   rP   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   z!AsyncWork.list.<locals>.<genexpr>ú  rY   r9   rZ   r{   r|   r}   r~   r€   )rb   r   r   rc   r	   r   r‚   r   r"   r+   r$   r   r%   rƒ   r„   s	            r7   r…   zAsyncWork.listÐ  s-  € ðJ ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ×!Ò!ÝÐLÐ]kÐlÑlÔlÝ Õ!3Ô4Ý(Ø+Ø'Ø%ØÝ%à!&Ø $ðð õ %Ô3ñô ðñ ô õ %ð! "ñ 
ô 
ð 	
r9   c          
   ƒ  ó   K  — |st          d|›�¦  «        ‚|st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d||¬¦  «        t          ||||¬	¦  «        t          ¬
¦  «        ƒ d{V —†S )r‡   rN   rO   rP   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   z AsyncWork.ack.<locals>.<genexpr>=  rY   r9   rZ   r‰   r\   r]   r^   NrŠ   re   s           r7   r‹   zAsyncWork.ack  sJ  è è € ðB ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpØð 	cÝÐaÐV]ÐaÐaÑbÔbÐbð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ—Z’ZÝØPØ-Øðñ ô õ
 )Ø+¸ÐQ[Ðelðñ ô õ 'ð  ñ 

ô 

ð 

ð 

ð 

ð 

ð 

ð 

ð 
	
r9   rŒ   r�   r�   rŽ   r-   c             ƒ  óä  K  — |st          d|›�¦  «        ‚|st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d||¬¦  «        t          ||||	t          ||d	œt          j        ¦  «        ƒ d
{V —†¬¦  «        t          ¬¦  «        ƒ d
{V —†S )r‘   rN   rO   rP   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   z&AsyncWork.heartbeat.<locals>.<genexpr>�  rY   r9   rZ   r“   r\   r”   Nr~   r^   )rb   r   r   rc   r	   r   rn   r   r$   r   r)   r•   r-   r–   s
             r7   r—   zAsyncWork.heartbeatQ  sŽ  è è € ðR ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpØð 	cÝÐaÐV]ÐaÐaÑbÔbÐbð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ—Z’ZÝØVØ-Øðñ ô õ
 )Ø+Ø'Ø%ØÝ1à/BØ3Jðð õ *Ô=ñô ð ð ð ð ð ð ðñ ô õ 8ð'  ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ð 	
r9   r˜   r™   rš   r›   rœ   r�   c             ƒ  ó¼  K  — |st          d|›�¦  «        ‚i t          t          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          |dœ¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d|¬¦  «        t          ||||	t          ||d	œt          j        ¦  «        ƒ d
{V —†¬¦  «        t          ¬¦  «        ƒ d
{V —†S )rŸ   rN   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   z!AsyncWork.poll.<locals>.<genexpr>Ð  rY   r9   rZ   r¡   rP   r¢   r|   r£   Nr~   r^   )rb   r   r   rc   r	   r   rd   r   r$   r   r&   r¤   r+   r¥   s
             r7   r¦   zAsyncWork.pollŸ  si  è è € ðX ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpð

Ýõ   ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"Ø+>ð	ð ñô ð

ð Ð" ð

ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ—Y’YÝÐQÐbpÐqÑqÔqÝ(Ø+Ø'Ø%ØÝ1à$,Ø1Fðð õ %Ô3ñô ð ð ð ð ð ð ðñ ô õ 'ð ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ð 	
r9   r,   c          
   ƒ  óv  K  — |st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d|¬¦  «        t          ||||¬¦  «        t          ¬	¦  «        ƒ d
{V —†S )r¨   rN   rP   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   z"AsyncWork.stats.<locals>.<genexpr>
  rY   r9   rZ   rª   r|   r]   r^   Nr«   r¬   s          r7   r­   zAsyncWork.statsë  s  è è € ð4 ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ—Y’YÝÐRÐcqÐrÑrÔrÝ(Ø+¸ÐQ[Ðelðñ ô õ 1ð ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ð 	
r9   r®   r¯   r°   c          
   ƒ  óâ  K  — |st          d|›�¦  «        ‚|st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d||¬¦  «        t          d	|it          j
        ¦  «        ƒ d
{V —†t          ||||¬¦  «        t          ¬¦  «        ƒ d
{V —†S )r²   rN   rO   rP   rQ   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rS   rT   rU   s     r7   rX   z!AsyncWork.stop.<locals>.<genexpr>D  rY   r9   rZ   r´   r\   r¯   Nr]   rl   )rb   r   r   rc   r	   r   rn   r   r   r'   rµ   r$   r+   r¶   s	            r7   r·   zAsyncWork.stop  sr  è è € ðF ð 	qÝÐoÐ]kÐoÐoÑpÔpÐpØð 	cÝÐaÐV]ÐaÐaÑbÔbÐbð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ—Z’ZÝØQØ-Øðñ ô õ
 -¨g°uÐ-=Õ?OÔ?^Ñ_Ô_Ð_Ð_Ð_Ð_Ð_Ð_Ý(Ø+¸ÐQ[Ðelðñ ô õ 'ð  ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ð 	
r9   FT)Ú	worker_idr™   rš   ÚdrainÚ	auto_stopr@   Úenvironment_keyrØ   ú
str | Noneúint | None | NotGivenú
int | NonerÙ   ÚboolrÚ   ú!AsyncIterator[BetaSelfHostedWork]c          
     óÆ   — ddl m}	 ddlm}
m} t          |¦  «        s|
} |	t          d| j        ¦  «        |d¬¦  «        } ||j        j	        j
        |||||||¬¦  «        S )uµ	  Async-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.
        r   )Ú_copy_client_with_bearer_auth)ÚPOLL_BLOCK_MSÚ
aiter_workr   zenvironments-work-poller)Ú
auth_tokenÚhelper)rF   rØ   r™   rš   rÙ   rÚ   r@   )Úlib._scoped_clientrâ   Úlib.environments._pollerrã   rä   r   r   Ú_clientÚbetaÚenvironmentsÚwork)r6   rF   rÛ   rØ   r™   rš   rÙ   rÚ   r@   râ   rã   rä   Úscopeds                r7   ÚpollerzAsyncWork.pollerY  s­   € ðr 	IÐHÐHÐHÐHÐHØJÐJÐJÐJÐJÐJÐJÐJå˜Ñ!Ô!ð 	%Ø$ˆHà.Ð.ÝÐ! 4¤<Ñ0Ô0Ø&Ø-ð
ñ 
ô 
ˆð
 ˆzØŒKÔ$Ô)Ø)ØØØ"7ØØØ'ð	
ñ 	
ô 	
ð 		
r9   ©	rF   rÛ   ÚtoolsÚworkdirÚunrestricted_pathsÚmax_file_bytesÚmax_idlerØ   r@   rð   úEnvironmentWorkerTools | Nonerñ   ústr | os.PathLike[str] | Nonerò   ró   rô   úfloat | None | NotGivenr   c       	        óŒ   — ddl m}
 ddlm} t	          |¦  «        s|} |
t          d| j        ¦  «        |||||||||	¬¦
  «
        S )um  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_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.
          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   )r   )ÚDEFAULT_MAX_IDLEr   rï   )Úlib.environments._workerr   Úlib.tools._beta_session_runnerrù   r   r   ré   )r6   rF   rÛ   rð   rñ   rò   ró   rô   rØ   r@   r   rù   s               r7   ÚworkerzAsyncWork.worker¨  s„   € ðB 	CÐBÐBÐBÐBÐBØGÐGÐGÐGÐGÐGå˜Ñ!Ô!ð 	(Ø'ˆHà Ð ÝÐ! 4¤<Ñ0Ô0Ø)Ø+ØØØ1Ø)ØØØ'ð
ñ 
ô 
ð 	
r9   )r1   rÃ   )r1   rÅ   r¸   r¹   )rF   rE   rs   ru   rt   rv   r?   rG   r@   rH   rA   rI   rB   rJ   rC   rK   r1   rË   rº   r»   r¼   r½   )rF   rE   rÛ   rE   rØ   rÜ   r™   rÝ   rš   rÞ   rÙ   rß   rÚ   rß   r@   rH   r1   rà   )rF   rÜ   rÛ   rÜ   rð   rõ   rñ   rö   rò   rß   ró   rÝ   rô   r÷   rØ   rÜ   r@   rH   r1   r   )r¾   r¿   rÀ   r   r8   r=   r   r   rf   rq   r…   r‹   r—   r¦   r­   r·   rî   rü   rÁ   r9   r7   r/   r/   A  sˆ  € € € € € Øð.ð .ð .ñ „_ð.ð ð4ð 4ð 4ñ „_ð4ð 26ð )-Ø$(Ø"&Ø;Dð9
ð 9
ð 9
ð 9
ð 9
ð 9
ðB 26ð )-Ø$(Ø"&Ø;Dð>
ð >
ð >
ð >
ð >
ð >
ðH !Ø%)Ø15ð )-Ø$(Ø"&Ø;DðC
ð C
ð C
ð C
ð C
ð C
ðT 26ð )-Ø$(Ø"&Ø;Dð:
ð :
ð :
ð :
ð :
ð :
ðB 59Ø8<Ø15ð )-Ø$(Ø"&Ø;DðL
ð L
ð L
ð L
ð L
ð L
ðd *.Ø6:Ø15Ø*.ð )-Ø$(Ø"&Ø;DðJ
ð J
ð J
ð J
ð J
ð J
ð` 26ð )-Ø$(Ø"&Ø;Dð-
ð -
ð -
ð -
ð -
ð -
ðh "Ø15ð )-Ø$(Ø"&Ø;Dð=
ð =
ð =
ð =
ð =
ð =
ðH !%Ø*3Ø,0ØØØ(,ðM
ð M
ð M
ð M
ð M
ð M
ðd &*Ø&*Ø/3Ø15Ø#(Ø09Ø,5Ø $Ø(,ðR
ð R
ð R
ð R
ð R
ð R
ð R
ð R
r9   c                  ó   — e Zd Zdd„ZdS )r2   rì   r.   r1   ÚNonec                óô  — || _         t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        t          j        |j	        ¦  «        | _	        t          j        |j
        ¦  «        | _
        d S rS   )Ú_workr   Úto_raw_response_wrapperrf   rq   r…   r‹   r—   r¦   r­   r·   ©r6   rì   s     r7   Ú__init__zWorkWithRawResponse.__init__þ  sã   € ØˆŒ
å(Ô@ØŒMñ
ô 
ˆŒõ 'Ô>ØŒKñ
ô 
ˆŒõ %Ô<ØŒIñ
ô 
ˆŒ	õ $Ô;ØŒHñ
ô 
ˆŒõ *ÔAØŒNñ
ô 
ˆŒõ %Ô<ØŒIñ
ô 
ˆŒ	õ &Ô=ØŒJñ
ô 
ˆŒ
õ %Ô<ØŒIñ
ô 
ˆŒ	ˆ	ˆ	r9   N©rì   r.   r1   rþ   ©r¾   r¿   rÀ   r  rÁ   r9   r7   r2   r2   ý  ó(   € € € € € ð
ð 
ð 
ð 
ð 
ð 
r9   r2   c                  ó   — e Zd Zdd„ZdS )rÃ   rì   r/   r1   rþ   c                óô  — || _         t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        t          j        |j	        ¦  «        | _	        t          j        |j
        ¦  «        | _
        d S rS   )r   r   Úasync_to_raw_response_wrapperrf   rq   r…   r‹   r—   r¦   r­   r·   r  s     r7   r  z!AsyncWorkWithRawResponse.__init__  sã   € ØˆŒ
å(ÔFØŒMñ
ô 
ˆŒõ 'ÔDØŒKñ
ô 
ˆŒõ %ÔBØŒIñ
ô 
ˆŒ	õ $ÔAØŒHñ
ô 
ˆŒõ *ÔGØŒNñ
ô 
ˆŒõ %ÔBØŒIñ
ô 
ˆŒ	õ &ÔCØŒJñ
ô 
ˆŒ
õ %ÔBØŒIñ
ô 
ˆŒ	ˆ	ˆ	r9   N©rì   r/   r1   rþ   r  rÁ   r9   r7   rÃ   rÃ     r  r9   rÃ   c                  ó   — e Zd Zdd„ZdS )r:   rì   r.   r1   rþ   c                ó¤  — || _         t          |j        ¦  «        | _        t          |j        ¦  «        | _        t          |j        ¦  «        | _        t          |j        ¦  «        | _        t          |j        ¦  «        | _        t          |j        ¦  «        | _        t          |j        ¦  «        | _        t          |j	        ¦  «        | _	        d S rS   )
r   r   rf   rq   r…   r‹   r—   r¦   r­   r·   r  s     r7   r  z"WorkWithStreamingResponse.__init__:  sË   € ØˆŒ
å4ØŒMñ
ô 
ˆŒõ 3ØŒKñ
ô 
ˆŒõ 1ØŒIñ
ô 
ˆŒ	õ 0ØŒHñ
ô 
ˆŒõ 6ØŒNñ
ô 
ˆŒõ 1ØŒIñ
ô 
ˆŒ	õ 2ØŒJñ
ô 
ˆŒ
õ 1ØŒIñ
ô 
ˆŒ	ˆ	ˆ	r9   Nr  r  rÁ   r9   r7   r:   r:   9  r  r9   r:   c                  ó   — e Zd Zdd„ZdS )rÅ   rì   r/   r1   rþ   c                ó¤  — || _         t          |j        ¦  «        | _        t          |j        ¦  «        | _        t          |j        ¦  «        | _        t          |j        ¦  «        | _        t          |j        ¦  «        | _        t          |j        ¦  «        | _        t          |j        ¦  «        | _        t          |j	        ¦  «        | _	        d S rS   )
r   r    rf   rq   r…   r‹   r—   r¦   r­   r·   r  s     r7   r  z'AsyncWorkWithStreamingResponse.__init__X  sË   € ØˆŒ
å:ØŒMñ
ô 
ˆŒõ 9ØŒKñ
ô 
ˆŒõ 7ØŒIñ
ô 
ˆŒ	õ 6ØŒHñ
ô 
ˆŒõ <ØŒNñ
ô 
ˆŒõ 7ØŒIñ
ô 
ˆŒ	õ 8ØŒJñ
ô 
ˆŒ
õ 7ØŒIñ
ô 
ˆŒ	ˆ	ˆ	r9   Nr
  r  rÁ   r9   r7   rÅ   rÅ   W  r  r9   rÅ   )FÚ
__future__r   ÚosÚtypingr   r   r   r   r   Ú	itertoolsr	   ÚhttpxÚcollections.abcr
   ré   r   rú   r   r   Ú r   Ú_typesr   r   r   r   r   r   r   Ú_utilsr   r   r   r   r   Ú_compatr   Ú	_resourcer   r   Ú	_responser   r    Ú
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/   r2   rÃ   r:   rÅ   rÁ   r9   r7   ú<module>r#     s;  ðð #Ð "Ð "Ð "Ð "Ð "à 	€	€	€	Ø <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ø Ð Ð Ð Ð Ð à €€€àð WØ-Ð-Ð-Ð-Ð-Ð-à*Ð*Ð*Ð*Ð*Ð*ØVÐVÐVÐVÐVÐVÐVÐVà !Ð !Ð !Ð !Ð !Ð !Ø LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LØ gÐ gÐ gÐ gÐ gÐ gÐ gÐ gÐ gÐ gÐ gÐ gÐ gÐ gØ 'Ð 'Ð 'Ð 'Ð 'Ð 'Ø ;Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;Ø ZÐ ZÐ ZÐ ZÐ ZÐ ZÐ ZÐ ZØ :Ð :Ð :Ð :Ð :Ð :Ð :Ð :Ø AÐ AÐ AÐ AÐ AÐ AÐ AÐ Aðð ð ð ð ð ð ð ð ð ð ð ð ð ð >Ð =Ð =Ð =Ð =Ð =Ø PÐ PÐ PÐ PÐ PÐ PØ fÐ fÐ fÐ fÐ fÐ fØ tÐ tÐ tÐ tÐ tÐ tà�;Ð
€ðV
ð V
ð V
ð V
ð V
ˆ?ñ V
ô V
ð V
ðry

ð y

ð y

ð y

ð y

Ð ñ y

ô y

ð y

ðx
ð 
ð 
ð 
ð 
ñ 
ô 
ð 
ð<
ð 
ð 
ð 
ð 
ñ 
ô 
ð 
ð<
ð 
ð 
ð 
ð 
ñ 
ô 
ð 
ð<
ð 
ð 
ð 
ð 
ñ 
ô 
ð 
ð 
ð 
r9   