from __future__ import absolute_import, unicode_literals import os from celery import Celery os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'gst_web_wallet.settings') app = Celery('gst_web_wallet') app.config_from_object('django.conf:settings', namespace='CELERY') # Load task modules from all registered Django app configs. app.autodiscover_tasks() app.conf.beat_schedule = { 'check-received-txs': { 'task': 'wallet.tasks.check_transactions_task', 'schedule': 120.0, # 'args': (123,), } } @app.task(bind=True) def debug_task(self): print('Request: {0!r}'.format(self.request))