django-celery

Turn Off Celery Tasks

Turn Off Celery Tasks
I'm trying to find a way to be able to turn celery tasks on/off from the django admin. This is mostly to disable tasks that call external services when those services are down or have a scheduled maintenance period.For my periodic tasks, this is easy

Django Celery in production

Django Celery in production
I have everything I want to do withdjango-celeryworking on my development machine locally. I run Django,djcelery,celleryand the broker (Amazon SQS). It sends tasks and just works.I can set this all up like I have done locally (i.e. all on one machine

Simply Import Task with Celery

Simply Import Task with Celery
I have a simple view which uploads CSV data to a mapped model and populates the data. This works perfect, but now I want to integrateCeleryand I'm really struggling to get the following task to work. I'm trying Celery with Django andAmazon SQS.This i

Processor Intensive Task For Django Celery

Processor Intensive Task For Django Celery
Let's suppose, just for the sake of an example, I have a Django web application that is used for processing video and I want to use celery to offload some of those tasks. If I have a task in Celery, such as video editing, that is extremely processor

Celery: per task concurrency limits (# of workers per task)?

Celery: per task concurrency limits (# of workers per task)?
Is it possible to set the concurrency (the number of simultaneous workers) on a per-task level inCelery? I'm looking for something more fine-grained thatCELERYD_CONCURRENCY(that sets the concurrency for the whole daemon).The usage scenario is: I have

Django Celery Directory Structure and Layout

Django Celery Directory Structure and Layout
I have a django project using the following directory structure.project/ account/ models.py views.py blog/ models.py views.py mediakit/ models.py views.py reports/ celery.py <-- new models.py tasks.py <-- new views.py settings/ __init__.py <-- pr

Celery: auto discovery does not find tasks module in app

Celery: auto discovery does not find tasks module in app
I have the following setup with a fresh installed celery and django 1.4:settings.py:import djcelery djcelery.setup_loader() BROKER_HOST = 'localhost' BROKER_PORT = 5672 BROKER_USER = 'user' BROKER_PASSWORD = 'password' BROKER_VHOST = 'test' [...] INS

Starting Celery: AttributeError: 'module' object has no attribute 'celery'

Starting Celery: AttributeError: 'module' object has no attribute 'celery'
I try to start a Celery worker server from a command line:celery -A tasks worker --loglevel=infoThe code in tasks.py:import os os.environ[ 'DJANGO_SETTINGS_MODULE' ] = "proj.settings" from celery import task @task() def add_photos_task( lad_id )

How to remove celery task ?

How to remove celery task ?
I practicedjango-celerysettings.py#import datetime #CELERYBEAT_SCHEDULE = { # 'hello_task': { # 'task': 'hello_task', # 'schedule': datetime.timedelta(seconds=20), # }, #} import datetime CELERYBEAT_SCHEDULE = { 'add-every-30-seconds': { 'task': 'app

How to set http_headers on celery tasks calls via http

How to set http_headers on celery tasks calls via http
I want to make a task call via HTTP using the class HttpDispatch from celery, but i need to set Authorization header. How can i do this?from celery.task.http import HttpDispatch request = HttpDispatch( url='http://example.com/multiply', method='GET',

Django celery multiple workers with specific concurrencies

Django celery multiple workers with specific concurrencies
I have to call some stored procedures from the database(oracle). I use celery and redis to call this SP in asynchronous [email protected] def carga_ftp(): tabla = Proc_Carga() sp = tabla.carga() return None @task def conci(idprov,pfecha): conci = Bus

Celery chain monitoring: the easy way

Celery chain monitoring: the easy way
Using django-celery-3.0.17, celery-3.0.21 and django-1.5.1, I'm trying to monitor a chain execution. I found a solution but it seems a little bit weird to me, so I'm searching for an easier solution if possible. Here's my code:views.pydef runCod(requ

DJANGO celery task is executed from shell but it's not executed from view

DJANGO celery task is executed from shell but it's not executed from view
I am trying to create some asynchronous tasks with celery in my django applicationsettings.pyBROKER_URL = 'django://localhost:6379/0' CELERY_ACCEPT_CONTENT = ['json'] CELERY_TASK_SERIALIZER = 'json' CELERY_RESULT_SERIALIZER = 'json'celery.py:from __f

Detect whether Celery is Available/Running

Detect whether Celery is Available/Running
I'm usingCeleryto manage asynchronous tasks. Occasionally, however, the celery process goes down which causes none of the tasks to get executed. I would like to be able to check the status of celery and make sure everything is working fine, and if I
What Others Are Reading