Documentation Index

Fetch the complete documentation index at: https://docs.prefect.io/llms.txt

Use this file to discover all available pages before exploring further.

​

prefect.client.schemas.worker_channel

​

Functions

​

validate_worker_channel_frame

validate_worker_channel_frame(frame: Any) -> WorkerChannelApplicationFrame

​

select_worker_channel_version

select_worker_channel_version(supported_versions: Iterable[str]) -> WorkerChannelVersion

​

Classes

​

WorkerChannelCloseReason

​

WorkerChannelClosePolicy

​

model_validate_list

model_validate_list(cls, obj: Any) -> list[Self]

​

reset_fields

reset_fields(self: Self) -> Self

• A new instance of the model with the reset fields.

​

WorkerChannelProtocolError

​

WorkerChannelContract

​

model_validate_list

model_validate_list(cls, obj: Any) -> list[Self]

​

reset_fields

reset_fields(self: Self) -> Self

• A new instance of the model with the reset fields.

​

WorkerChannelAuthRequest

​

WorkerChannelAuthSuccess

​

WorkerChannelFrame

​

WorkerHelloPayload

​

default_cleanup_concurrency

default_cleanup_concurrency(cls, data: Any) -> Any

​

required_capabilities_are_requested

required_capabilities_are_requested(self) -> WorkerHelloPayload

​

WorkerHelloFrame

​

ResolvedWorkQueue

​

WorkPoolSnapshot

​

helpful_error_for_missing_default_queue_id

helpful_error_for_missing_default_queue_id(cls, v: Optional[UUID]) -> UUID

​

is_managed_pool

is_managed_pool(self) -> bool

​

is_push_pool

is_push_pool(self) -> bool

​

WorkPoolSnapshotPayload

​

WorkerReadyPayload

​

validate_capability_decision

validate_capability_decision(self) -> WorkerReadyPayload

​

WorkerReadyFrame

​

WorkerHeartbeatPayload

​

WorkerHeartbeatFrame

​

WorkPoolSnapshotFrame

​

CancellingTimeoutTeardownTarget

​

model_validate_list

model_validate_list(cls, obj: Any) -> list[Self]

​

reset_fields

reset_fields(self: Self) -> Self

• A new instance of the model with the reset fields.

​

PendingClaimTeardownTarget

​

model_validate_list

model_validate_list(cls, obj: Any) -> list[Self]

​

reset_fields

reset_fields(self: Self) -> Self

• A new instance of the model with the reset fields.

​

CancellingTimeoutCleanupMessagePayload

​

PendingClaimCleanupMessagePayload

​

CleanupMessageFrame

​

CleanupOperationPayload

​

CleanupReleasePayload

​

CleanupAckFrame

​

CleanupReleaseFrame

​

CleanupRenewFrame

​

CleanupOperationResultPayload

​

validate_result_contract

validate_result_contract(self) -> CleanupOperationResultPayload

​

CleanupOperationResultFrame