diff --git a/DjangoFiles/AuthBillet/tasks.py b/DjangoFiles/AuthBillet/tasks.py index 8f73dc5..79bd54d 100644 --- a/DjangoFiles/AuthBillet/tasks.py +++ b/DjangoFiles/AuthBillet/tasks.py @@ -1,8 +1,2 @@ # Create your tasks here -from celery import shared_task - - -@shared_task -def add(x, y): - return x + y \ No newline at end of file diff --git a/DjangoFiles/TiBillet/celery.py b/DjangoFiles/TiBillet/celery.py index e87bcd7..4f58e53 100644 --- a/DjangoFiles/TiBillet/celery.py +++ b/DjangoFiles/TiBillet/celery.py @@ -35,15 +35,9 @@ app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) @app.task(bind=True) -def debug_task(self): - print(f'Request: {self.request}') - - -@app.task def add(x, y): return x + y - @app.task -def my_task(): - print(connection.schema_name) +def add2(x, y): + return x + y diff --git a/DjangoFiles/TiBillet/settings.py b/DjangoFiles/TiBillet/settings.py index 71871e4..ac1eb01 100644 --- a/DjangoFiles/TiBillet/settings.py +++ b/DjangoFiles/TiBillet/settings.py @@ -217,8 +217,8 @@ CELERY_TIMEZONE=os.environ.get('TIME_ZONE', 'UTC') CELERY_TASK_TRACK_STARTED=True CELERY_TASK_TIME_LIMIT=30 * 60 BROKER_URL=os.environ.get('CELERY_BROKER') -# CELERY_BROKER=os.environ.get('CELERY_BROKER') -# CELERY_BROKER_URL=os.environ.get('CELERY_BROKER') +RESULT_BACKEND=os.environ.get('CELERY_BROKER') +CELERY_RESULT_BACKEND=os.environ.get('CELERY_BACKEND') # DJANGO_CELERY_BEAT_TZ_AWARE=False # celery -A TiBillet worker -l INFO