from django.core.management.base import BaseCommand, CommandError from celery.task.control import inspect class Command(BaseCommand): help = 'Initiates data dase' def handle(self, *args, **options): i = inspect() print('Show the items that have an ETA or are scheduled for later processing') print(i.scheduled()) print('Show tasks that are currently active.') print(i.active()) print('Show tasks that have been claimed by workers') print(i.reserved())