revoke_by_stamped_headers

Revoke task by header (or list of headers).

def revoke_by_stamped_headers(
    state: object,
    headers: dict|list,
    terminate: boolean = False,
    signal: string = None,
    **kwargs: any
) - > object

Revoke task by header (or list of headers).

Parameters

Name	Type	Description
state	object	The current worker or consumer state object used to access the execution pool.
headers	`dict	list`
terminate	boolean = False	If True, immediately terminates the process of any active tasks that match the provided stamped headers.
signal	string = None	The name of the cryptographic or system signal (e.g., 'KILL' or 'TERM') to send when terminating active tasks.
**kwargs	any	Additional keyword arguments passed to the control command handler.

Returns

Type	Description
object	A status object indicating whether the headers were flagged for revocation and if any active tasks were successfully terminated.