i = tasks.app.control.inspect()  # 创建inspect对象，可以操作tasks的队列管理
i.active(safe=None)  # Return list of tasks currently executed by workers.
i.reserved(safe=None)  # Return list of currently reserved tasks, not including scheduled/active

 celery.app.control — Celery 5.3.4 documentation

两万字长文让你彻底掌握 celery