pool_shrink

Shrink pool by n processes/threads.

def pool_shrink(
    state: object,
    n: int = 1,
    **kwargs: dict
) - > dict

Shrink pool by n processes/threads.

Parameters

Name	Type	Description
state	object	The current application state containing the consumer and controller instances.
n	int = 1	The number of worker processes or threads to remove from the execution pool.
**kwargs	dict	Additional keyword arguments passed to the control command.

Returns

Type	Description
dict	A dictionary containing a status message indicating whether the shrink operation was initiated or if it failed due to autoscaling being enabled.