Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat(celery): Set "messaging.system" on span #3024

Open
wants to merge 2 commits into
base: szokeasaurusrex/celery-messaging-id
Choose a base branch
from

Conversation

szokeasaurusrex
Copy link
Member

@szokeasaurusrex szokeasaurusrex commented Apr 26, 2024

Marked as "Work in progress" since I still need to test this PR more thoroughly

Depends on:

ref #2951

@szokeasaurusrex szokeasaurusrex force-pushed the szokeasaurusrex/celery-queue-consumer-default-exchange branch from f1671f5 to 67e2531 Compare April 30, 2024 15:16
@szokeasaurusrex szokeasaurusrex force-pushed the szokeasaurusrex/celery-messaging-system branch from 45e8f3b to cd65142 Compare April 30, 2024 15:49
@szokeasaurusrex szokeasaurusrex changed the base branch from szokeasaurusrex/celery-queue-consumer-default-exchange to szokeasaurusrex/celery-messaging-id April 30, 2024 15:50
@szokeasaurusrex szokeasaurusrex self-assigned this Apr 30, 2024
@szokeasaurusrex szokeasaurusrex force-pushed the szokeasaurusrex/celery-messaging-system branch 4 times, most recently from 55ba199 to a09959b Compare May 3, 2024 12:07
events = capture_events()

# Does not need to be a real URL, since we use always eager
celery.conf.broker_url = f"{system}://example.com" # noqa: E231
Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Flake8 is giving a false positive E231 on the : in the string when running in CI

@szokeasaurusrex szokeasaurusrex force-pushed the szokeasaurusrex/celery-messaging-system branch 4 times, most recently from 92846d8 to 4af0ecb Compare May 7, 2024 12:59
@@ -28,7 +28,7 @@ def init_celery(sentry_init, request):
def inner(propagate_traces=True, backend="always_eager", **kwargs):
sentry_init(
integrations=[CeleryIntegration(propagate_traces=propagate_traces)],
**kwargs
**kwargs,
Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The formatter is adding this comment, and if I try to commit with the comma remove, CI fails. So I will keep it here

@szokeasaurusrex szokeasaurusrex changed the title WIP: feat(celery): Set "messaging.system" on span feat(celery): Set "messaging.system" on span May 7, 2024
@szokeasaurusrex szokeasaurusrex marked this pull request as ready for review May 7, 2024 13:05
@szokeasaurusrex szokeasaurusrex force-pushed the szokeasaurusrex/celery-messaging-id branch from d5a29b9 to df18b49 Compare May 7, 2024 15:56
The messaging.system span data attribute should be set to the Celery broker being used, e.g. "amqp" for RabbitMQ, "redis" for Redis, and "sqs" for Amazon SQS.

ref #2951
@szokeasaurusrex szokeasaurusrex force-pushed the szokeasaurusrex/celery-messaging-system branch from 4af0ecb to fa16def Compare May 7, 2024 16:00
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

1 participant