Celeryd

From Federal Burro of Information
Jump to navigationJump to search


http://docs.celeryproject.org/en/latest/userguide/workers.html?highlight=revoke#inspecting-workers


You should look here: Celery Guide - Inspecting Workers

Basically this:

>>> from celery.task.control import inspect

# Inspect all nodes.
>>> i = inspect()

# Show the items that have an ETA or are scheduled for later processing
>>> i.scheduled()

# Show tasks that are currently active.
>>> i.active()

# Show tasks that have been claimed by workers
>>> i.reserved()