diff --git a/worker/celery.py b/worker/celery.py index 98a7806..1292f15 100644 --- a/worker/celery.py +++ b/worker/celery.py @@ -14,12 +14,14 @@ host = rabbit_creds["host"] port = rabbit_creds["port"] + def init_tracing(): logging.info("Initializing trace...") otel_endpoint = os.getenv("TRACELOOP_BASE_URL") Traceloop.init(app_name="hivemind-server", api_endpoint=otel_endpoint) logging.info("Trace initialized...") + app = Celery( "tasks", broker=f"pyamqp://{user}:{password}@{host}:{port}//",