ray.serve.schema.TaskProcessorAdapter.initialize# abstract TaskProcessorAdapter.initialize(consumer_concurrency: int = 5)[source]# Initialize the task processor.