cancel_consumer
Tell worker(s) to stop consuming from task queue by name.
def cancel_consumer(
state: State,
queue: str
) - > dict
Tell worker(s) to stop consuming from task queue by name.
Parameters
| Name | Type | Description |
|---|---|---|
| state | State | The current worker state object containing the consumer instance |
| queue | str | The name of the task queue to stop consuming from |
Returns
| Type | Description |
|---|---|
dict | A success response dictionary containing a confirmation message that the worker is no longer consuming from the specified queue |