lint fixes

libs/queue/test/batch-processor.test.ts

@@ -38,7 +38,7 @@ describe('Batch Processor', () => {
       'generic': async (payload) => {
         return { processed: true, data: payload };
       },
-      'process-batch-items': async (batchData) => {
+      'process-batch-items': async (_batchData) => {
         // This is called by the batch processor internally
         return { batchProcessed: true };
       },
@@ -87,7 +87,7 @@ describe('Batch Processor', () => {
           await queue.getBullQueue().clean(0, 1000, 'active');
           await queue.getBullQueue().clean(0, 1000, 'waiting');
           await queue.getBullQueue().clean(0, 1000, 'delayed');
-        } catch (error) {
+        } catch {
           // Ignore cleanup errors
         }
         await queue.close();

libs/queue/test/dlq-handler.test.ts

@@ -1,5 +1,5 @@
 import { describe, test, expect, beforeEach, afterEach } from 'bun:test';
-import { Queue, Worker, Job } from 'bullmq';
+import { Queue, Worker } from 'bullmq';
 import { DeadLetterQueueHandler } from '../src/dlq-handler';
 import { getRedisConnection } from '../src/utils';
 
@@ -50,7 +50,7 @@ describe('DeadLetterQueueHandler', () => {
       }
       await dlqHandler.shutdown();
       await mainQueue.close();
-    } catch (error) {
+    } catch {
       // Ignore cleanup errors
     }
     await new Promise(resolve => setTimeout(resolve, 50));
@@ -70,7 +70,7 @@ describe('DeadLetterQueueHandler', () => {
       });
 
       // Add job with limited attempts
-      const job = await mainQueue.add('failing-job', { test: true }, {
+      const _job = await mainQueue.add('failing-job', { test: true }, {
         attempts: 3,
         backoff: { type: 'fixed', delay: 50 },
       });

libs/queue/test/queue-manager.test.ts

@@ -121,7 +121,7 @@ describe('QueueManager', () => {
       let processedCount = 0;
 
       handlerRegistry.register('bulk-handler', {
-        process: async payload => {
+        process: async _payload => {
           processedCount++;
           return { processed: true };
         },
@@ -237,7 +237,7 @@ describe('QueueManager', () => {
       handlerRegistry.registerWithSchedule({
         name: 'scheduled-handler',
         operations: {
-          'scheduled-task': async payload => {
+          'scheduled-task': async _payload => {
             executionCount++;
             return { executed: true, timestamp: Date.now() };
           },

libs/queue/test/queue-metrics.test.ts

@@ -51,7 +51,7 @@ describe('QueueMetricsCollector', () => {
       }
       await queueEvents.close();
       await queue.close();
-    } catch (error) {
+    } catch {
       // Ignore cleanup errors
     }
     await new Promise(resolve => setTimeout(resolve, 50));

libs/queue/test/queue-simple.test.ts

@@ -18,7 +18,7 @@ describe('QueueManager Simple Tests', () => {
     if (queueManager) {
       try {
         await queueManager.shutdown();
-      } catch (error) {
+      } catch {
         // Ignore errors during cleanup
       }
     }

libs/queue/test/rate-limiter.test.ts

@@ -36,7 +36,7 @@ describe('QueueRateLimiter', () => {
       if (keys.length > 0) {
         await redisClient.del(...keys);
       }
-    } catch (error) {
+    } catch {
       // Ignore cleanup errors
     }
     rateLimiter = new QueueRateLimiter(redisClient);
@@ -46,7 +46,7 @@ describe('QueueRateLimiter', () => {
     if (redisClient) {
       try {
         await redisClient.quit();
-      } catch (error) {
+      } catch {
         // Ignore cleanup errors
       }
     }