ci: Improve Redis client disconnection handling in integration tests

- Updated the afterAll cleanup logic in integration tests for GenerationJobManager, RedisEventTransport, and RedisJobStore to use `quit()` for graceful disconnection of the Redis client.
- Added fallback to `disconnect()` if `quit()` fails, enhancing robustness in resource management during test teardown.
- Improved comments for clarity on the disconnection process and error handling.

packages/api/src/stream/__tests__/GenerationJobManager.stream_integration.spec.ts

@@ -45,11 +45,17 @@ describe('GenerationJobManager Integration Tests', () => {
   });
 
   afterAll(async () => {
-    if (ioredisClient && 'disconnect' in ioredisClient) {
+    if (ioredisClient) {
       try {
-        ioredisClient.disconnect();
+        // Use quit() to gracefully close - waits for pending commands
+        await ioredisClient.quit();
       } catch {
-        // Ignore disconnect errors
+        // Fall back to disconnect if quit fails
+        try {
+          ioredisClient.disconnect();
+        } catch {
+          // Ignore
+        }
       }
     }
     process.env = originalEnv;

packages/api/src/stream/__tests__/RedisEventTransport.stream_integration.spec.ts

@@ -29,11 +29,17 @@ describe('RedisEventTransport Integration Tests', () => {
   });
 
   afterAll(async () => {
-    if (ioredisClient && 'disconnect' in ioredisClient) {
+    if (ioredisClient) {
       try {
-        ioredisClient.disconnect();
+        // Use quit() to gracefully close - waits for pending commands
+        await ioredisClient.quit();
       } catch {
-        // Ignore
+        // Fall back to disconnect if quit fails
+        try {
+          ioredisClient.disconnect();
+        } catch {
+          // Ignore
+        }
       }
     }
     process.env = originalEnv;

packages/api/src/stream/__tests__/RedisJobStore.stream_integration.spec.ts

@@ -57,11 +57,17 @@ describe('RedisJobStore Integration Tests', () => {
   });
 
   afterAll(async () => {
-    if (ioredisClient && 'disconnect' in ioredisClient) {
+    if (ioredisClient) {
       try {
-        ioredisClient.disconnect();
+        // Use quit() to gracefully close - waits for pending commands
+        await ioredisClient.quit();
       } catch {
-        // Ignore disconnect errors
+        // Fall back to disconnect if quit fails
+        try {
+          ioredisClient.disconnect();
+        } catch {
+          // Ignore
+        }
       }
     }
     process.env = originalEnv;