Metadata-Version: 2.1
Name: veggie
Version: 0.1.12
Summary: A tool to monitor and execute Celery tasks
Author: Theodore Tsitsimis
Author-email: th.tsitsimis@gmail.com
Classifier: Development Status :: 3 - Alpha
Classifier: Intended Audience :: Developers
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: License :: OSI Approved :: MIT License
Description-Content-Type: text/markdown
License-File: LICENSE

<p align="center">
    <img src="https://raw.githubusercontent.com/tsitsimis/veggie/refs/heads/main/assets/logo-big.svg" alt="logo" width=200 style="background: white; border-radius: 50%"/>
    <div align="center" style="font-size: 1.5em">Veggie - Celery monitoring and execution</div>
</p>
<p align="center">
    <img src="https://img.shields.io/badge/Python-3.11%2B-blue">
    <img src="https://badgen.net/pypi/license/veggie">
    <a href="https://pypi.org/project/veggie/"><img src="https://badgen.net/pypi/v/veggie"></a>
    <img src="https://img.shields.io/badge/Framework-Celery-9cf">
    <img src="https://github.com/tsitsimis/veggie/actions/workflows/ci.yml/badge.svg">
</p>

Veggie is a web-based tool for monitoring the status of Celery tasks and starting tasks through a UI. It stores Celery events in a SQLite database but allows easy switch to another user-defined storage backend.

## Installation
```bash
pip install veggie
```

## Quickstart
To enable better task monitoring, add the following to your Celery application:
```python
celery_app = Celery("myapp")

celery_app.conf.worker_send_task_events = True  # Enables task events
celery_app.conf.task_send_sent_event = True  # Enables sent events
celery_app.conf.task_track_started = True  # Update task result state to STARTED
celery_app.conf.result_extended = True  # Store args and kwargs in the result
```

Start monitoring by adding the following to your Celery application or in a separate script:
```python
from veggie.monitor import CeleryMonitor
from veggie.storage import SQLiteStorage

os.environ["VEGGIE_PORT"] = "5000"  # Set port for the UI and API

if __name__ == "__main__":
    celery_monitor = CeleryMonitor(celery_app=celery_app, storage=SQLiteStorage(path="events.db")) # or any other storage class that inherits from veggie.storage.Storage
    celery_monitor.start()
```

Open your browser at `http://localhost:5000`:

Check the status of past and running tasks:
<p align="center">
    <img src="https://raw.githubusercontent.com/tsitsimis/veggie/refs/heads/main/assets/status.png" width="100%"/>
</p>

Select a task to view its details:
<p align="center">
    <img src="https://raw.githubusercontent.com/tsitsimis/veggie/refs/heads/main/assets/event-details.png" width="100%"/>
</p>


Start a new task by entering values for its parameters through the UI:
<p align="center">
    <img src="https://raw.githubusercontent.com/tsitsimis/veggie/refs/heads/main/assets/start-task.png" width="100%"/>
</p>

See the `example` folder for a full example.

## REST API
Access the API at `http://localhost:5000/api/`

## Configure your own storage backend
All storage implementations should inherit from the `veggie.storage.Storage` class and implement the `store_event()`, `get_events()` and `get_event_by_id()` methods. For an example, check the [SQLiteStorage](veggie/storage.py) implementation.
