Flush Redis after feature workers stop

Author: durable-workflow-ops

tests/TestCase.php

@@ -29,17 +29,7 @@ public static function setUpBeforeClass(): void
             }
         }
 
-        $redisHost = getenv('REDIS_HOST') ?: ($_ENV['REDIS_HOST'] ?? null);
-        $redisPort = getenv('REDIS_PORT') ?: ($_ENV['REDIS_PORT'] ?? 6379);
-        if ($redisHost && class_exists(\Redis::class)) {
-            try {
-                $redis = new \Redis();
-                $redis->connect($redisHost, (int) $redisPort);
-                $redis->flushDB();
-            } catch (\Throwable $e) {
-                // Ignore if no redis
-            }
-        }
+        self::flushRedis();
 
         for ($i = 0; $i < self::NUMBER_OF_WORKERS; $i++) {
             self::$workers[$i] = new Process(['php', __DIR__ . '/../vendor/bin/testbench', 'queue:work']);
@@ -53,6 +43,10 @@ public static function tearDownAfterClass(): void
         foreach (self::$workers as $worker) {
             $worker->stop();
         }
+
+        self::$workers = [];
+
+        self::flushRedis();
     }
 
     protected function setUp(): void
@@ -67,17 +61,7 @@ protected function setUp(): void
 
         Cache::flush();
 
-        $redisHost = getenv('REDIS_HOST') ?: ($_ENV['REDIS_HOST'] ?? null);
-        $redisPort = getenv('REDIS_PORT') ?: ($_ENV['REDIS_PORT'] ?? 6379);
-        if ($redisHost && class_exists(\Redis::class)) {
-            try {
-                $redis = new \Redis();
-                $redis->connect($redisHost, (int) $redisPort);
-                $redis->flushDB();
-            } catch (\Throwable $e) {
-                // Ignore if no redis
-            }
-        }
+        self::flushRedis();
     }
 
     protected function defineDatabaseMigrations()
@@ -94,4 +78,19 @@ protected function getPackageProviders($app)
     {
         return [\Workflow\Providers\WorkflowServiceProvider::class];
     }
+
+    private static function flushRedis(): void
+    {
+        $redisHost = getenv('REDIS_HOST') ?: ($_ENV['REDIS_HOST'] ?? null);
+        $redisPort = getenv('REDIS_PORT') ?: ($_ENV['REDIS_PORT'] ?? 6379);
+        if ($redisHost && class_exists(\Redis::class)) {
+            try {
+                $redis = new \Redis();
+                $redis->connect($redisHost, (int) $redisPort);
+                $redis->flushDB();
+            } catch (\Throwable $e) {
+                // Ignore if no redis
+            }
+        }
+    }
 }