app.celery.ContextTask.shadow_name

ContextTask.shadow_name(args, kwargs, options)

Override for custom task name in worker logs/monitoring.

Example

from celery.utils.imports import qualname

def shadow_name(task, args, kwargs, options):
    return qualname(args[0])

@app.task(shadow_name=shadow_name, serializer='pickle')
def apply_function_async(fun, *args, **kwargs):
    return fun(*args, **kwargs)

Parameters

• args (Tuple) – Task positional arguments.

• kwargs (Dict) – Task keyword arguments.

• options (Dict) – Task execution options.