Built-in Task Classes - celery.task.builtins

class celery.task.builtins.AsynchronousMapTask

Task used internally by dmap_async() and TaskSet.map_async().

run(serfunc, args, **kwargs)
The method run by celeryd.
class celery.task.builtins.DeleteExpiredTaskMetaTask

A periodic task that deletes expired task metadata every day.

This runs the current backend’s celery.backends.base.BaseBackend.cleanup() method.

run(**kwargs)
The method run by celeryd.
class celery.task.builtins.ExecuteRemoteTask

Execute an arbitrary function or object.

Note You probably want execute_remote() instead, which this is an internal component of.

The object must be pickleable, so you can’t use lambdas or functions defined in the REPL (that is the python shell, or ipython).

run(ser_callable, fargs, fkwargs, **kwargs)
Parameters:
  • ser_callable – A pickled function or callable object.
  • fargs – Positional arguments to apply to the function.
  • fkwargs – Keyword arguments to apply to the function.
class celery.task.builtins.PingTask

The task used by ping().

run(**kwargs)
Returns:the string "pong".

Previous topic

Task Registry - celery.registry

Next topic

Task Discovery - celery.discovery

This Page