Override for custom task name in worker logs/monitoring. Example: .. code-block:: python from celery.utils.imports import qualname def shadow_name(task, args, kwargs, options): return qualname(args[0]) @app.t
(self, args, kwargs, options)
| 632 | ) |
| 633 | |
| 634 | def shadow_name(self, args, kwargs, options): |
| 635 | """Override for custom task name in worker logs/monitoring. |
| 636 | |
| 637 | Example: |
| 638 | .. code-block:: python |
| 639 | |
| 640 | from celery.utils.imports import qualname |
| 641 | |
| 642 | def shadow_name(task, args, kwargs, options): |
| 643 | return qualname(args[0]) |
| 644 | |
| 645 | @app.task(shadow_name=shadow_name, serializer='pickle') |
| 646 | def apply_function_async(fun, *args, **kwargs): |
| 647 | return fun(*args, **kwargs) |
| 648 | |
| 649 | Arguments: |
| 650 | args (Tuple): Task positional arguments. |
| 651 | kwargs (Dict): Task keyword arguments. |
| 652 | options (Dict): Task execution options. |
| 653 | """ |
| 654 | |
| 655 | def signature_from_request(self, request=None, args=None, kwargs=None, |
| 656 | queue=None, **extra_options): |