diff --git a/conf/supervisor.conf b/conf/supervisor.conf index 6e0cb02..f6d36ef 100644 --- a/conf/supervisor.conf +++ b/conf/supervisor.conf @@ -37,7 +37,7 @@ startsecs=10 stopwaitsecs=600 [program:flower] -command=celery -A src.dokumentor flower -l info -E -B --unix_socket=/tmp/flower.sock +command=celery -A src.dokumentor flower -l info -E -B --unix_socket=/tmp/flower.sock --broker=amqp://dokumentor:dokumentor@rabbitmq:5672// directory=/opt/app stdout_logfile=/var/log/celery-flower.log stderr_logfile=/var/log/celery-flower-error.log diff --git a/src/customer/tasks.py b/src/customer/tasks.py index bf67857..11422f2 100644 --- a/src/customer/tasks.py +++ b/src/customer/tasks.py @@ -7,7 +7,7 @@ from django.core.urlresolvers import reverse from django.utils import timezone from datetime import datetime, timedelta -from celery import shared_task +from celery import shared_task, task from django.core.mail import mail_admins @@ -104,3 +104,8 @@ def check_not_paid_accounts(): account_list.append(account) return account_list + + +@task +def test(arg): + print(arg) diff --git a/src/dokumentor/settings/common.py b/src/dokumentor/settings/common.py index aa5e085..e92125c 100644 --- a/src/dokumentor/settings/common.py +++ b/src/dokumentor/settings/common.py @@ -284,6 +284,11 @@ CELERYBEAT_SCHEDULE = { 'task': 'src.customer.tasks.check_not_paid_accounts', 'schedule': timedelta(days=1), }, + 'test_task': { + 'task': 'src.customer.tasks.test', + 'schedule': 30.0, + 'args': (16, 16) + }, } CAPTCHA_OUTPUT_FORMAT = \