Stream feature worker output in CI

Author: durable-workflow-ops

.github/workflows/php.yml

@@ -82,13 +82,15 @@ jobs:
         DB_CONNECTION: mysql
         DB_PORT: ${{ job.services.mysql.ports[3306] }}
         QUEUE_CONNECTION: redis
+        WORKFLOW_TEST_STREAM_WORKER_OUTPUT: 1
 
     - name: Run test suite (PostgreSQL)
       run: vendor/bin/phpunit --testdox --debug --testsuite feature
       env:
         DB_CONNECTION: pgsql
         DB_PORT: ${{ job.services.postgres.ports[5432] }}
         QUEUE_CONNECTION: redis
+        WORKFLOW_TEST_STREAM_WORKER_OUTPUT: 1
 
     - name: Upload laravel.log if tests fail
       if: failure()

tests/TestCase.php

@@ -43,8 +43,15 @@ public static function setUpBeforeClass(): void
 
         for ($i = 0; $i < self::NUMBER_OF_WORKERS; $i++) {
             self::$workers[$i] = new Process(['php', __DIR__ . '/../vendor/bin/testbench', 'queue:work']);
-            self::$workers[$i]->disableOutput();
-            self::$workers[$i]->start();
+            if (! self::shouldStreamWorkerOutput()) {
+                self::$workers[$i]->disableOutput();
+                self::$workers[$i]->start();
+                continue;
+            }
+
+            self::$workers[$i]->start(static function (string $type, string $output) use ($i): void {
+                fwrite(STDERR, '[worker-' . $i . '][' . $type . '] ' . $output);
+            });
         }
     }
 
@@ -94,4 +101,11 @@ protected function getPackageProviders($app)
     {
         return [\Workflow\Providers\WorkflowServiceProvider::class];
     }
+
+    private static function shouldStreamWorkerOutput(): bool
+    {
+        $value = getenv('WORKFLOW_TEST_STREAM_WORKER_OUTPUT') ?: ($_ENV['WORKFLOW_TEST_STREAM_WORKER_OUTPUT'] ?? null);
+
+        return in_array($value, ['1', 'true', 'yes', 'on'], true);
+    }
 }