ARQ

pip install --upgrade "sentry-sdk[arq]"

import sentry_sdk
from sentry_sdk.integrations.arq import ArqIntegration


sentry_sdk.init(
    dsn="...",
    integrations=[
        ArqIntegration(),
    ],
    traces_sample_rate=1.0,
)


async def add_numbers(ctx, a, b):
    return a + b


class WorkerSettings:
    functions = [add_numbers]

import asyncio
import sentry_sdk
from sentry_sdk.integrations.arq import ArqIntegration
from sentry_sdk.tracing import TRANSACTION_SOURCE_COMPONENT


async def main():
    sentry_sdk.init(
        dsn="...",
        integrations=[
            ArqIntegration(),
        ],
        traces_sample_rate=1.0,
    )

    redis = await create_pool(RedisSettings())

    with sentry_sdk.start_transaction(name="testing_arq_jobs", source=TRANSACTION_SOURCE_COMPONENT):
        r = await redis.enqueue_job("download_content", 1, 2)


if __name__ == "__main__":
    asyncio.run(main())