ray.serve.schema.TaskProcessorAdapter.start_consumer#

abstract TaskProcessorAdapter.start_consumer(**kwargs)[source]#

Start the task consumer/worker process.