ray.serve.schema.TaskProcessorConfig#

class ray.serve.schema.TaskProcessorConfig(*, queue_name: str, adapter: str | Callable = 'ray.serve.task_processor.CeleryTaskProcessorAdapter', adapter_config: Any, max_retries: int | None = 3, failed_task_queue_name: str | None = None, unprocessable_task_queue_name: str | None = None)[source]#

Bases: BaseModel

Task processor config. You can use it to configure the 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

`queue_name`
`adapter`
`adapter_config`
`max_retries`
`failed_task_queue_name`
`unprocessable_task_queue_name`