Skip to content
This repository was archived by the owner on Jun 13, 2025. It is now read-only.

Commit 7f75f3b

Browse files
committed
remove manual celery wrapping
1 parent c748b1c commit 7f75f3b

File tree

1 file changed

+0
-15
lines changed

1 file changed

+0
-15
lines changed

services/task/task.py

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,8 @@
22
from datetime import datetime, timedelta
33
from typing import Iterable, List, Optional, Tuple
44

5-
import celery
65
from celery import Celery, chain, group, signature
7-
from celery.canvas import Signature
8-
from django.conf import settings
96
from sentry_sdk import set_tag
10-
from sentry_sdk.integrations.celery import _wrap_apply_async
117
from shared import celery_config
128

139
from core.models import Repository
@@ -19,17 +15,6 @@
1915

2016
log = logging.getLogger(__name__)
2117

22-
if settings.SENTRY_ENV:
23-
celery.group.apply_async = _wrap_apply_async(celery.group.apply_async)
24-
celery.chunks.apply_async = _wrap_apply_async(celery.chunks.apply_async)
25-
celery.canvas._chain.apply_async = _wrap_apply_async(
26-
celery.canvas._chain.apply_async
27-
)
28-
celery.canvas._chord.apply_async = _wrap_apply_async(
29-
celery.canvas._chord.apply_async
30-
)
31-
Signature.apply_async = _wrap_apply_async(Signature.apply_async)
32-
3318

3419
class TaskService(object):
3520
def _create_signature(self, name, args=None, kwargs=None, immutable=False):

0 commit comments

Comments
 (0)