Try Ray with $100 credit — Start now

ray.serve.schema.TaskProcessorConfig#

pydantic model ray.serve.schema.TaskProcessorConfig[source]#

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.

field adapter: str | Callable = 'ray.serve.task_processor.CeleryTaskProcessorAdapter'#: The adapter to use for task processing. By default, Celery is used.

field adapter_config: Any [Required]#: The adapter config.

field failed_task_queue_name: str | None = None#: The name of the failed task queue. This is used to move failed tasks to a dead-letter queue after max retries.

field max_retries: int | None = 3#: The maximum number of times to retry a task before marking it as failed.

field queue_name: str [Required]#: The name of the queue to use for task processing.

field unprocessable_task_queue_name: str | None = None#: The name of the unprocessable task queue. This is used to move unprocessable tasks(like tasks with serialization issue, or missing handler) to a dead-letter queue.