Celery MCP

A Python library that provides a connector to use Celery distributed task queues over the Model Context Protocol (MCP).

Features

• Seamless integration of Celery with MCP

• Easy-to-use API for task management

• Support for asynchronous task execution

• MCP server with tools for LLM interaction

• Comprehensive documentation and examples

Installation

Install from PyPI:

Or install from source:

Quick Start

Using the Python API

Using the MCP Server

The package includes an MCP server that exposes Celery functionality as tools that can be used by LLMs:

Available MCP Tools

1. initialize_celery_connection - Initialize connection to Celery broker

2. list_registered_tasks - List all registered task names

3. send_task - Send a task to the Celery queue

4. get_task_status - Get the status of a Celery task

5. get_active_tasks - Get information about active (running) tasks

6. get_scheduled_tasks - Get information about scheduled tasks

7. revoke_task - Revoke (cancel) a task

8. get_worker_stats - Get statistics about Celery workers

MCP Client Configuration

To use the MCP server with Claude Desktop, add this to your claude_desktop_config.json:

Documentation

Full documentation is available at https://celery-mcp.readthedocs.io/.

Contributing

We welcome contributions! Please see our Contributing Guide for details.

License

This project is licensed under the MIT License - see the LICENSE file for details.

Support

If you have any questions or issues, please open an issue on GitHub.