import logging

import sentry_sdk
from celery import Celery
from sentry_sdk.integrations.celery import CeleryIntegration

log = logging.getLogger(__name__)

sentry_sdk.init(
    environment='testing',
    release='1.41.0',
    traces_sample_rate=1.0,
    integrations=[CeleryIntegration(propagate_traces=True)],
)

app = Celery(broker='pyamqp://guest:guest@localhost:5672//')
app.conf.task_always_eager = False


@app.task(name='baggage_issue', bind=True, acks_late=True, default_retry_delay=0, max_retries=5)
def baggage_issue(self):
    with sentry_sdk.start_transaction(name='baggage_issue', op="celery", sampled=True):
        baggage = (self.request.headers or {}).get('baggage', '')
        log.info('%s %s', len(baggage), baggage)
        self.retry(countdown=0)


# if __name__ == '__main__':
with sentry_sdk.start_transaction(name='baggage_issue', op="celery", sampled=True):
    baggage_issue.delay()