A Django helper to monitor jobs running Celery tasks
Project description
Django-Celery-GrowthMonitor
A Django helper to monitor jobs running Celery tasks
Features
Utilities to track progress of Celery tasks via in-database jobs
Designed for jobs with user-uploaded files
Requirements
Installation
Using PyPI
Run pip install django-celery-growthmonitor
Using the source code
Make sure pandoc is installed
Run ./pypi_packager.sh
Run pip install dist/django_celery_growthmonitor-x.y.z-[...].wheel, where x.y.z must be replaced by the actual version number and [...] depends on your packaging configuration
Usage
('state', echoices.fields.make_echoicefield(default=celery_growthmonitor.models.AJob.EState.CREATED, echoices=celery_growthmonitor.models.AJob.EState, editable=False)),
('status', echoices.fields.make_echoicefield(default=celery_growthmonitor.models.AJob.EStatus.ACTIVE, echoices=celery_growthmonitor.models.AJob.EStatus, editable=False)),
from .celery import app
@app.task
def my_task(holder: JobHolder, *args):
job = holder.get_job()
if job.has_failed():
# Just skip the whole if the previous task failed
return holder.pre_serialization()
# Some processing
...
job.save()
return holder.pre_serialization()
Helpers
Automatically set the job failed on task failure using custom base Task class
from celery_growthmonitor.models.task import JobFailedOnFailureTask
@app.task(base=JobFailedOnFailureTask, bind=True)
def my_task(self, holder: JobHolder):
pass
Admin
from django.contrib import admin
from celery_growthmonitor.admin import AJobAdmin
@admin.register(MyJob)
class MyJobAdmin(AJobAdmin):
fields = AJobAdmin.fields + ('my_extra_field',)
readonly_fields = AJobAdmin.readonly_fields + ('my_extra_field',)
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for django-celery-growthmonitor-1.0.1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | f8130cbea1b70ba8f0083b4022ca6c839853d8ff17b81b458bf202ca15316aef |
|
MD5 | cf7fc3cbb4731d99c69e78a2926ba94c |
|
BLAKE2b-256 | 84d5549582b07e88d048afed6f84738f01bcf7dea06bd62445f36ab93dcefc82 |
Close
Hashes for django_celery_growthmonitor-1.0.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 1513e36874bdb7ddd92b50f7c1eda11976e3a1279473607911b2ac3454e482fd |
|
MD5 | 4851d3caabdfa55f6c4e6554d9af6b16 |
|
BLAKE2b-256 | faf0c7ac885f9aa3f9368b06e102c6be0c72640d766e7b0cde62436be1acc022 |