Skip to main content

redis_echo_group_id

Appends the current task's group ID to a specified Redis list using a reliable connection.

def redis_echo_group_id(
self: celery.app.task.Task,
_: any,
redis_key: string = "redis-group-ids"
) - > null

Appends the current Celery task group ID to a specified Redis list for tracking or synchronization purposes.

Parameters

NameTypeDescription
selfcelery.app.task.TaskThe task instance, used to access the current request context and group metadata.
_anyAn ignored positional argument, typically used for compatibility with Celery signal or link signatures.
redis_keystring = "redis-group-ids"The key name of the Redis list where the group ID will be stored.

Returns

TypeDescription
nullThis function does not return a value.