Capture CI worker output to files

Author: durable-workflow-ops

.github/workflows/php.yml

@@ -82,22 +82,24 @@ jobs:
         DB_CONNECTION: mysql
         DB_PORT: ${{ job.services.mysql.ports[3306] }}
         QUEUE_CONNECTION: redis
-        WORKFLOW_TEST_STREAM_WORKER_OUTPUT: 1
+        WORKFLOW_TEST_CAPTURE_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
+        WORKFLOW_TEST_CAPTURE_WORKER_OUTPUT: 1
 
     - name: Upload laravel.log if tests fail
       if: failure()
       uses: actions/upload-artifact@v4
       with:
         name: laravel-log
-        path: vendor/orchestra/testbench-core/laravel/storage/logs/laravel.log
+        path: |
+          vendor/orchestra/testbench-core/laravel/storage/logs/laravel.log
+          vendor/orchestra/testbench-core/laravel/storage/logs/workflow-test-worker-*.log
 
     - name: Code Coverage
       run: |

tests/TestCase.php

@@ -43,14 +43,16 @@ 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']);
-            if (! self::shouldStreamWorkerOutput()) {
+            if (! self::shouldCaptureWorkerOutput()) {
                 self::$workers[$i]->disableOutput();
                 self::$workers[$i]->start();
                 continue;
             }
 
+            file_put_contents(self::workerLogPath($i), '');
+
             self::$workers[$i]->start(static function (string $type, string $output) use ($i): void {
-                fwrite(STDERR, '[worker-' . $i . '][' . $type . '] ' . $output);
+                file_put_contents(self::workerLogPath($i), $output, FILE_APPEND | LOCK_EX);
             });
         }
     }
@@ -102,10 +104,19 @@ protected function getPackageProviders($app)
         return [\Workflow\Providers\WorkflowServiceProvider::class];
     }
 
-    private static function shouldStreamWorkerOutput(): bool
+    private static function shouldCaptureWorkerOutput(): bool
     {
-        $value = getenv('WORKFLOW_TEST_STREAM_WORKER_OUTPUT') ?: ($_ENV['WORKFLOW_TEST_STREAM_WORKER_OUTPUT'] ?? null);
+        $value = getenv(
+            'WORKFLOW_TEST_CAPTURE_WORKER_OUTPUT'
+        ) ?: ($_ENV['WORKFLOW_TEST_CAPTURE_WORKER_OUTPUT'] ?? null);
 
         return in_array($value, ['1', 'true', 'yes', 'on'], true);
     }
+
+    private static function workerLogPath(int $worker): string
+    {
+        return dirname(
+            __DIR__
+        ) . '/vendor/orchestra/testbench-core/laravel/storage/logs/workflow-test-worker-' . $worker . '.log';
+    }
 }