Celery Flower Mcp

devops-infra MCP Server

MCP server for Celery Flower — monitor workers, manage tasks and queues from any AI assistant

VerifiedInstall Ready
devops-infradevops-infra
5 views3 stars0 forksMIT

Why This Matters

Discovered via github-topic:mcp and last synced 3mo ago.

VerifiedInstall Ready
Source
github-topic:mcp
Stars
3
Last synced
3mo ago
Install
Instructions detected

Install

1. Install the package

uvx celery-flower-mcp

2. Add to claude_desktop_config.json

{
  "mcpServers": {
    "celery-flower-mcp": {
      "command": "npx",
      "args": [
        "celery-flower-mcp"
      ]
    }
  }
}

Config file location: ~/Library/Application Support/Claude/claude_desktop_config.json (macOS) / %APPDATA%\Claude\claude_desktop_config.json (Windows)

27
Tools
0
Resources
0
Prompts
Standard I/O
Transport

Available Tools (27)

Variable

Default

shutdown_worker

Gracefully shut down a worker

list_task_types

List all registered task types across workers

set_task_rate_limit

Set rate limit for a task on a worker (e.g. `100/m`)

restart_worker_pool

Restart a worker's process pool

get_task_info

Get full details for a task by UUID

FLOWER_URL

`http://localhost:5555`

shrink_worker_pool

Remove N processes from a worker's pool

apply_task

Execute a task synchronously and wait for the result

healthcheck

Check whether the Flower instance is reachable and healthy

FLOWER_PASSWORD

add_queue_consumer

Make a worker start consuming from a queue

send_task

Send a task by name — no registration required on worker side

FLOWER_API_TOKEN

cancel_queue_consumer

Make a worker stop consuming from a queue

abort_task

Abort a running task

list_workers

List all workers — optionally filter by name, refresh live stats, or get status only

list_tasks

List tasks with filters: state, worker, name, date range, search, pagination

set_task_timeout

Set soft and/or hard time limits for a task on a worker

FLOWER_USERNAME

autoscale_worker_pool

Configure autoscale min/max bounds

async_apply_task

Dispatch a task asynchronously, returns task UUID

Tool

Description

revoke_task

Revoke a task; optionally terminate with a signal

grow_worker_pool

Add N processes to a worker's pool

get_task_result

Retrieve a task's result (with optional timeout)

get_queue_lengths

Get the current depth of all configured queues