Task used internally by dmap_async() and TaskSet.map_async().
A periodic task that deletes expired task metadata every day.
This runs the current backend’s celery.backends.base.BaseBackend.cleanup() method.
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).
Parameters: |
|
---|