"""Loads celery or non-celery version."""
from django.conf import settings

try:
    from .tasks import write_points as write_points_celery
except Exception:
    write_points_celery = None

from .utils import write_points as write_points_normal

write_points = None
if getattr(settings, 'INFLUXDB_USE_CELERY', False):
    write_points = write_points_celery.delay
else:
    write_points = write_points_normal

@@ -144,17 +144,19 @@
 ept 
-Exception
+ImportError
 :%0A  

Fix to not silently swallow all Exceptions.