ray.serve.schema.TaskProcessorAdapter.stop_consumer#

abstract TaskProcessorAdapter.stop_consumer(timeout: float = 10.0)[source]#

Stop the task consumer gracefully.

Parameters:

timeout – Maximum time in seconds to wait for the consumer to stop.