diff --git a/package-lock.json b/package-lock.json index 49e81f8..9bc4324 100644 --- a/package-lock.json +++ b/package-lock.json @@ -1,12 +1,12 @@ { "name": "@athenna/queue", - "version": "5.24.0", + "version": "5.25.0", "lockfileVersion": 3, "requires": true, "packages": { "": { "name": "@athenna/queue", - "version": "5.24.0", + "version": "5.25.0", "license": "MIT", "dependencies": { "@aws-sdk/client-sqs": "^3.1019.0" diff --git a/package.json b/package.json index 67016fc..1b1fe2c 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@athenna/queue", - "version": "5.24.0", + "version": "5.25.0", "description": "The Athenna queue handler.", "license": "MIT", "author": "João Lenon ", diff --git a/tests/unit/kernels/WorkerKernelTest.ts b/tests/unit/kernels/WorkerKernelTest.ts index 1438c0e..3e38bf6 100644 --- a/tests/unit/kernels/WorkerKernelTest.ts +++ b/tests/unit/kernels/WorkerKernelTest.ts @@ -9,13 +9,14 @@ import { Queue } from '#src/facades/Queue' import { Worker } from '#src/facades/Worker' -import { context, createContextKey } from '@opentelemetry/api' +import { OtelProvider } from '@athenna/otel' import { Path, Sleep } from '@athenna/common' import { LoggerProvider } from '@athenna/logger' import { WorkerImpl } from '#src/worker/WorkerImpl' import { WorkerKernel } from '#src/kernels/WorkerKernel' import { constants } from '#tests/fixtures/constants/index' import { QueueProvider } from '#src/providers/QueueProvider' +import { context, createContextKey } from '@opentelemetry/api' import { WorkerProvider } from '#src/providers/WorkerProvider' import { AsyncLocalStorageContextManager } from '@opentelemetry/context-async-hooks' import { Test, BeforeEach, AfterEach, type Context, Mock, Cleanup } from '@athenna/test' @@ -30,6 +31,7 @@ export class WorkerKernelTest { WorkerImpl.rTracerPlugin = undefined await Config.loadAll(Path.fixtures('config')) + new OtelProvider().register() new LoggerProvider().register() new QueueProvider().register() new WorkerProvider().register() @@ -40,6 +42,7 @@ export class WorkerKernelTest { Mock.restoreAll() context.disable() + await new OtelProvider().shutdown() new WorkerProvider().shutdown() constants.RUN_MAP.helloWorker = false