Questions tagged [django-celery-beat]
88 questions
12
votes
1 answer
Django run tasks (possibly) in the far future
Suppose I have a model Event. I want to send a notification (email, push, whatever) to all invited users once the event has elapsed. Something along the lines of:
class Event(models.Model):
start = models.DateTimeField(...)
end =…
Hafnernuss
- 2,659
- 2
- 29
- 41
4
votes
2 answers
Executing two celery workers from one line
I am working on a project for my university within a team where I was mostly working on the frontend and some basic django models, so I am not so familiar and eloquent with django-celery and I also did not set it up. At first we were using one…
Trollgon
- 45
- 1
- 5
3
votes
1 answer
Celery beat sends the same task twice to the worker on every interval
I have the following scheduled task in example_app -> tasks.py:
@app.on_after_configure.connect
def setup_periodic_tasks(sender, **kwargs):
sender.add_periodic_task(
crontab(minute='*/1'),
test.s(),
)
@app.task
def test():
…
codego
- 97
- 8
3
votes
5 answers
Why am I getting "No module named 'django_celery_beat'" after installing django_celery_beat to my virtual env and putting it in INSTALLED_APPS?
I am working on a Django project, and need to run cron tasks periodically to go through and delete all outdated files. I tried this same method with django_extensions and crontab, but I keep getting this same error. Within settings.py, I…
DaeyongK
- 71
- 1
- 3
3
votes
1 answer
dbbackup with docker/celery/celery-beat not working: no error but no file stored?
EDIT4 29/12/2020:
I tought it could be DEBUG settings but neither works
I've read many toturial and documentation and I do not understand what is wrong with my code here for example
EDIT3 29/12/2020:
I try call_command('flush','--noinput') and…
Mereva
- 350
- 2
- 14
2
votes
1 answer
monitoring celery task in Django
I am using celery-results and celery-beats in my Django app. I am using React framework in my frontend and I'd like to create a component to monitor all statuses in all celery tasks but celery-beats displays only statuses: STARTED, FAILURE, SUCCESS.…
Adrian
- 725
- 4
- 18
2
votes
0 answers
Get Celery worker total number of processed tasks on SQS broker
I've been googling all day for what I believe is a pretty straightforward thing but found no indication on how to achieve the following:
I have several machines running celery workers (celery worker -A app --pool=gevent --concurrency=10), AWS SQS as…
Arjuna Del Toso
- 579
- 3
- 13
2
votes
0 answers
remove registred celery tasks from drop down menu django admin
I have several registred tasks. Сan I not show some of them? For example, so that the drop-down menu does not have main.tasks._start_proxy_loading
Ciganeshima
- 57
- 6
2
votes
2 answers
Celery Beat acknowledging a task, running it but not executing it
The problem is I get the following log:
celery_1 | [2021-03-15 19:00:00,124: INFO/MainProcess] Scheduler: Sending due task read_dof (api.tasks.read_dof)
celery_1 | [2021-03-15 19:00:00,140: INFO/MainProcess] Scheduler: Sending due task read_bdm…
paula.em.lafon
- 553
- 2
- 6
- 15
2
votes
1 answer
Unable to Run Celery and celery beat using docker in django application (Unable to load celery application)
when I am trying to run my application I using without docker its working perfectly , but In docker-compose I am getting this error :
| Error: Invalid value for '-A' / '--app':
| Unable to load celery application.
…
tempaccount as
- 173
- 1
- 2
- 10
2
votes
2 answers
Django Celery Beat and Tasks Results
Is it possible for django-celery-beat not to save tasks that are performed in a short time interval? By default, all results are saved to the Task Results table.
I cannot find this information on celeryproject webpage.
Alternatively, what should be…
OceanFire
- 504
- 4
- 11
1
vote
1 answer
celery beat schedule: why one same task is completed in different time durations?
I have used celery-beat to get data from about 30 different APIs and save them in database.
There are two prblems:
first: why it takes so long to do the task (i thought it shouldn't take more than 2-3 seconds)?
second: why a single task takes…
webdeveloper
- 27
- 5
1
vote
0 answers
Django/Celery - Filter each task result with periodic_task_name
I am quite new to Celery. Here is my code for configuring Celery Beat.
app.conf.beat_schedule = {
# EMAILS
'send-feedback-mail-every-2-weeks': {
'task': 'stocks.tasks.send_ask_feedback',
'schedule': crontab(day_of_week=6),
…
mika
- 86
- 8
1
vote
1 answer
Get scrapy spider response back on django Rest api GET
I'm working project it contains a GET request with a few parameters suchas (airline code and flight date), I pass those parameters to a crawler coded using scrapy . I've created Django command in management/commands to hit the scrapy crawler and as…
Raheel Siddiqui
- 95
- 6
1
vote
1 answer
Celery scheduler not performing the task
I was trying to use Celery to query an external api at a regular frequency and update my database in my Django project with the new data. Celery schedules the task correctly and sends it to the celery worker but it never executes anything.
Here is…
the_nerdman
- 17
- 5