Django==3.2.15 celery v5.1.2 и jango-celery-beat==2.2.1 включают задачу и ничего не происходит

Ок весь день пытается понять, что не так.

mysite.settings

mysite.celery.py

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
import requests
from django.utils import timezone
#from celery.contrib import rdb

# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'mysite.settings')

app = Celery('mysite')

# Optional configuration, see the application user guide.
app.conf.update(
    result_expires=3600,
)

if __name__ == '__main__':
    app.start()

# Using a string here means the worker doesn't have to serialize
# the configuration object to child processes.
# - namespace='CELERY' means all celery-related configuration keys
#   should have a `CELERY_` prefix.

app.config_from_object('django.conf:settings', namespace='CELERY')

# Load task modules from all registered Django app configs.
app.autodiscover_tasks()

@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))

@app.task(bind=True)
def hello_world(self):
    print('Hello world!')
 

beat установлен и работает нормально на страницах администратора можно увидеть задачу hello_world в зарегистрированных задачах и установить интервал 15 секунд

Я запускаю celery worker с и получаю

celery -A mysite worker -l INFO -P gevent
celery@DESKTOP-65V2VTJ v5.1.2 (sun-harmonics)       
--- ***** -----
-- ******* ---- Windows-10-10.0.19041-SP0 2022-10-31 15:33:23       
- *** --- * ---
- ** ---------- [config]
- ** ---------- .> app:         mysite:0x28bba8b0ef0
- ** ---------- .> transport:   amqp://guest:**@localhost:5672//    
- ** ---------- .> results:       
- *** --- * --- .> concurrency: 12 (gevent)
-- ******* ---- .> task events: ON--- ***** -----
 -------------- [queues]
                .> celery
  exchange=celery(direct) key=celery


[tasks]
  . correlator.tasks.add
  . correlator.tasks.mul
  . iris.tasks.add
  . iris.tasks.mul
  . mysite.celery.debug_task      
  . mysite.celery.hello_world     
  . reviews.tasks.add
  . reviews.tasks.mul
  . reviews.tasks.rename_widget   

[2022-10-31 15:33:23,540: INFO/MainProcess] Connected to amqp://guest:**@127.0.0.1:5672//
[2022-10-31 15:33:23,544: INFO/MainProcess] mingle: searching for neighbors
[2022-10-31 15:33:24,564: INFO/MainProcess] mingle: all alone       
[2022-10-31 15:33:24,573: WARNING/MainProcess] c:\users\mikeoliver\github\correlator-2\venv\lib\site-packages\celery\fixups\django.py:204: UserWarning: Using settings.DEBUG leads to a memory
            leak, never use this setting in production environments!  leak, never use this setting in 
production environments!''')      

[2022-10-31 15:33:24,574: INFO/MainProcess] celery@DESKTOP-65V2VTJ ready.
[2022-10-31 15:33:24,577: INFO/MainProcess] pidbox: Connected to amqp://guest:**@127.0.0.1:5672//. 

Я начинаю бить

celery beat    
celery beat v5.1.2 (sun-harmonics) is starting.
__    -    ... __   -        _
LocalTime -> 2022-10-31 15:34:11 
Configuration ->
    . broker -> amqp://guest:**@localhost:5672//




    . loader -> celery.loaders.default.Loader
    . scheduler -> celery.beat.PersistentScheduler
    . db -> celerybeat-schedule  
    . logfile -> [stderr]@%WARNING
    . maxinterval -> 5.00 minutes (300s)

Но когда я изменяю расписание или что-либо в любой из зарегистрированных задач, я ничего не вижу ни в одном из трех терминалов после сохранения в терминале runserver.

Вернуться на верх