Setup Sentry in the Celery worker (#474)

Author: ambv

miss_islington/__main__.py

@@ -5,9 +5,7 @@
 
 import aiohttp
 import cachetools
-import sentry_sdk
 from aiohttp import web
-from sentry_sdk.integrations.celery import CeleryIntegration
 from gidgethub import aiohttp as gh_aiohttp
 from gidgethub import routing, sansio
 
@@ -20,9 +18,6 @@
 cache = cachetools.LRUCache(maxsize=500)
 
 
-sentry_sdk.init(os.environ.get("SENTRY_DSN"), integrations=[CeleryIntegration()])
-
-
 async def main(request):
     try:
         body = await request.read()

miss_islington/tasks.py

@@ -1,18 +1,19 @@
-import celery
 import asyncio
 import os
 import subprocess
-import aiohttp
-from gidgethub import aiohttp as gh_aiohttp
 
+import aiohttp
 import cachetools
-
-from celery import bootsteps
-
+import celery
 from cherry_picker import cherry_picker
+from celery import bootsteps
+from gidgethub import aiohttp as gh_aiohttp
+import sentry_sdk
+from sentry_sdk.integrations.celery import CeleryIntegration
 
 from . import util
 
+
 app = celery.Celery("backport_cpython")
 
 app.conf.update(
@@ -21,6 +22,8 @@
 )
 
 cache = cachetools.LRUCache(maxsize=500)
+sentry_sdk.init(os.environ.get("SENTRY_DSN"), integrations=[CeleryIntegration()])
+
 
 CHERRY_PICKER_CONFIG = {
     "team": "python",