ray.serve.schema.CeleryAdapterConfig

class ray.serve.schema.CeleryAdapterConfig(*, broker_url: str, backend_url: str, broker_transport_options: Dict[str, Any] | None = None, worker_concurrency: int | None = 10)

Bases: BaseModel

Celery adapter config. You can use it to configure the Celery task processor for your Serve application.

PublicAPI (alpha): This API is in alpha and may change before becoming stable.

Methods

__init__	Create a new model by parsing and validating input data from keyword arguments.
construct	Creates a new model setting __dict__ and __fields_set__ from trusted or pre-validated data.
copy	Duplicate a model, optionally choose which fields to include, exclude and change.
dict	Generate a dictionary representation of the model, optionally specifying which fields to include or exclude.
json	Generate a JSON representation of the model, include and exclude arguments as per dict().
update_forward_refs	Try to update ForwardRefs on fields based on this Model, globalns and localns.

Attributes

broker_url
backend_url
broker_transport_options
worker_concurrency