Skip to content
This repository was archived by the owner on Jun 13, 2025. It is now read-only.
Closed
Show file tree
Hide file tree
Changes from 3 commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion requirements.in
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ factory-boy
fakeredis
freezegun
https://github.com/codecov/opentelem-python/archive/refs/tags/v0.0.4a1.tar.gz#egg=codecovopentelem
https://github.com/codecov/shared/archive/9c31870de026a8a3f026f0753b1991e8c832fadb.tar.gz#egg=shared
https://github.com/codecov/shared/archive/12361de9ed29116b068805c1f7bfd90e9d659de5.tar.gz#egg=shared
google-cloud-pubsub
gunicorn>=22.0.0
https://github.com/photocrowd/django-cursor-pagination/archive/f560902696b0c8509e4d95c10ba0d62700181d84.tar.gz
Expand Down
2 changes: 1 addition & 1 deletion requirements.txt
Original file line number Diff line number Diff line change
Expand Up @@ -411,7 +411,7 @@ sentry-sdk[celery]==2.13.0
# shared
setproctitle==1.1.10
# via -r requirements.in
shared @ https://github.com/codecov/shared/archive/9c31870de026a8a3f026f0753b1991e8c832fadb.tar.gz
shared @ https://github.com/codecov/shared/archive/12361de9ed29116b068805c1f7bfd90e9d659de5.tar.gz
# via -r requirements.in
simplejson==3.17.2
# via -r requirements.in
Expand Down
17 changes: 7 additions & 10 deletions services/task/task.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
from celery.canvas import Signature
from django.conf import settings
from sentry_sdk import set_tag
from sentry_sdk.integrations.celery import _wrap_apply_async
from sentry_sdk.integrations.celery import _wrap_task_run
from shared import celery_config

from core.models import Repository
Expand All @@ -19,16 +19,13 @@

log = logging.getLogger(__name__)

# https://github.com/getsentry/sentry-python/issues/1416
if settings.SENTRY_ENV:
celery.group.apply_async = _wrap_apply_async(celery.group.apply_async)
celery.chunks.apply_async = _wrap_apply_async(celery.chunks.apply_async)
celery.canvas._chain.apply_async = _wrap_apply_async(
celery.canvas._chain.apply_async
)
celery.canvas._chord.apply_async = _wrap_apply_async(
celery.canvas._chord.apply_async
)
Signature.apply_async = _wrap_apply_async(Signature.apply_async)
celery.group.apply_async = _wrap_task_run(celery.group.apply_async)
celery.chunks.apply_async = _wrap_task_run(celery.chunks.apply_async)
celery.canvas._chain.apply_async = _wrap_task_run(celery.canvas._chain.apply_async)
celery.canvas._chord.apply_async = _wrap_task_run(celery.canvas._chord.apply_async)
Signature.apply_async = _wrap_task_run(Signature.apply_async)


class TaskService(object):
Expand Down
Loading