작업

작업 항목 조회

BetaSelfHostedWork beta().environments().work().retrieve(params, requestOptions = RequestOptions.none())

GET/v1/environments/{environment_id}/work/{work_id}

참고: 이 엔드포인트는 자체 호스팅 샌드박스 환경에서 세션을 오케스트레이션하기 위해 SDK 및 CLI에서 제공하는 사전 빌드된 환경 워커에 의해 자동으로 호출됩니다. 참조용으로 여기에 포함되어 있으며, 직접 호출할 필요는 없습니다.

작업 폴링

BetaSelfHostedWork beta().environments().work().poll(params = WorkPollParams.none(), requestOptions = RequestOptions.none())

GET/v1/environments/{environment_id}/work/poll

작업 확인

BetaSelfHostedWork beta().environments().work().ack(params, requestOptions = RequestOptions.none())

POST/v1/environments/{environment_id}/work/{work_id}/ack

참고: 이러한 엔드포인트는 자체 호스팅 샌드박스 환경과의 세션을 오케스트레이션하기 위해 SDK 및 CLI에서 제공되는 사전 빌드된 환경 워커에 의해 자동으로 호출됩니다. 참조용으로 여기에 포함되어 있으며, 직접 호출할 필요는 없습니다.

하트비트 기록

BetaSelfHostedWorkHeartbeatResponse beta().environments().work().heartbeat(params, requestOptions = RequestOptions.none())

POST/v1/environments/{environment_id}/work/{work_id}/heartbeat

작업 중지

BetaSelfHostedWork beta().environments().work().stop(params, requestOptions = RequestOptions.none())

POST/v1/environments/{environment_id}/work/{work_id}/stop

작업 항목 나열

WorkListPage beta().environments().work().list(params = WorkListParams.none(), requestOptions = RequestOptions.none())

GET/v1/environments/{environment_id}/work

작업 항목 업데이트

BetaSelfHostedWork beta().environments().work().update(params, requestOptions = RequestOptions.none())

POST/v1/environments/{environment_id}/work/{work_id}

큐 통계 가져오기

BetaSelfHostedWorkQueueStats beta().environments().work().stats(params = WorkStatsParams.none(), requestOptions = RequestOptions.none())

GET/v1/environments/{environment_id}/work/stats

환경의 작업 큐에 대한 통계를 가져옵니다.

Models

class BetaSelfHostedWork { type = "work"; id; acknowledgedAt; /* 10 more */ }

Work resource representing a unit of work in a self-hosted environment.

Work items are queued when sessions are created or when long-dormant sessions receive new messages. The environment worker polls for work to execute in a self-hosted sandbox.

class BetaSelfHostedWorkHeartbeatResponse { type = "work_heartbeat"; lastHeartbeat; leaseExtended; /* 2 more */ }

Response after recording a heartbeat for a work item.

JsonValue type = "work_heartbeat"

The type of response

String lastHeartbeat

RFC 3339 timestamp of the actual heartbeat from DB

boolean leaseExtended

Whether the heartbeat succeeded in extending the lease

State state

Current state of the work item (active/stopping/stopped)

One of the following:

QUEUED("queued")

STARTING("starting")

ACTIVE("active")

STOPPING("stopping")

STOPPED("stopped")

long ttlSeconds

Effective TTL applied to the lease

class BetaSelfHostedWorkListResponse { data; nextPage; }

Response when listing work items with cursor-based pagination.

class BetaSelfHostedWorkQueueStats { type = "work_queue_stats"; depth; oldestQueuedAt; /* 2 more */ }

Statistics about the work queue for an environment.

Uses Redis Stream consumer group metrics for O(1) queries.

JsonValue type = "work_queue_stats"

The type of object

long depth

Number of work items waiting to be picked up (lag from consumer group)

Optional<String> oldestQueuedAt

RFC 3339 timestamp of oldest item in the work stream (includes both queued and pending items), null if stream empty

long pending

Number of work items being processed (polled but not acknowledged)

Optional<Long> workersPolling

Number of workers that have polled for work in the last 30 seconds. Requires worker_id to be sent with poll requests.

class BetaSelfHostedWorkStopRequest { force; }

Request to stop a work item.

Optional<Boolean> force

If true, immediately stop work without graceful shutdown

class BetaSelfHostedWorkUpdateRequest { metadata; }

Request to update work item metadata.

Metadata 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.

class BetaSessionWorkData { type = "session"; id; }

Work data for session work items.

This resource type is used when work represents a session that needs to be executed in a self-hosted environment.

JsonValue type = "session"

Type of work data

String id

Session identifier (e.g., 'session_...')