1
0
Fork 0

Enable opbeat logging on Celery tasks

merge-requests/187/head
Nikos Roussos 2017-05-31 21:18:03 +03:00
parent 0e42bf583e
commit d1d6f07139
No known key found for this signature in database
GPG Key ID: BADFF1767BA7C8E1
1 changed files with 11 additions and 0 deletions

View File

@ -3,6 +3,8 @@ from __future__ import absolute_import
import os
from celery import Celery
from opbeat.contrib.django.models import client, logger, register_handlers
from opbeat.contrib.celery import register_signal
import dotenv
@ -26,3 +28,12 @@ def setup_periodic_tasks(sender, **kwargs):
sender.add_periodic_task(RUN_DAILY, update_all_tle.s(),
name='update-all-tle')
try:
register_signal(client)
except Exception as e:
logger.exception('Failed installing celery hook: %s' % e)
if 'opbeat.contrib.django' in settings.INSTALLED_APPS:
register_handlers()