test_runner: fix run() none-isolation teardown hang

lib/internal/test_runner/runner.js

@@ -944,6 +944,12 @@ function run(options = kEmptyObject) {
         finishBootstrap();
         return root.processPendingSubtests();
       };
+
+      if (!isTestRunner) {
+        // run() API consumers can keep handles alive (e.g., IPC). Finalize
+        // without waiting for beforeExit so the stream can close promptly.
+        teardown = () => root.harness.teardown();
+      }
     }
   }
 

test/fixtures/test-runner/run-isolation-none-in-cluster.js

@@ -0,0 +1,44 @@
+'use strict';
+
+const cluster = require('node:cluster');
+const { join } = require('node:path');
+const { run } = require('node:test');
+
+if (cluster.isPrimary) {
+  cluster.fork().on('exit', (code, signal) => {
+    if (signal !== null) {
+      process.stderr.write(`worker exited with signal ${signal}\n`);
+      process.exit(1);
+    }
+
+    process.exit(code ?? 0);
+  });
+} else {
+  // Repro based on: https://github.com/nodejs/node/issues/60020
+  const stream = run({
+    isolation: 'none',
+    files: [
+      join(__dirname, 'default-behavior', 'test', 'random.cjs'),
+    ],
+  });
+
+  async function consumeStream() {
+    for await (const data of stream) {
+      if (data === undefined) {
+        continue;
+      }
+    }
+    process.stdout.write('on end\n');
+    process.exit(0);
+  }
+
+  consumeStream().catch((err) => {
+    process.stderr.write(`worker error: ${err}\n`);
+    process.exit(1);
+  });
+
+  setTimeout(() => {
+    process.stderr.write('worker timed out waiting for end\n');
+    process.exit(1);
+  }, 3000).unref();
+}

test/parallel/test-runner-run.mjs

@@ -1,6 +1,7 @@
 import * as common from '../common/index.mjs';
 import * as fixtures from '../common/fixtures.mjs';
 import { join } from 'node:path';
+import { spawnSync } from 'node:child_process';
 import { describe, it, run } from 'node:test';
 import { dot, spec, tap } from 'node:test/reporters';
 import consumers from 'node:stream/consumers';
@@ -646,6 +647,19 @@ describe('require(\'node:test\').run', { concurrency: true }, () => {
       assert.strictEqual(diagnostics.includes(entry), true);
     }
   });
+
+  // Regression test for https://github.com/nodejs/node/issues/60020
+  it('should not hang in cluster workers when isolation is none', () => {
+    const fixture = fixtures.path('test-runner', 'run-isolation-none-in-cluster.js');
+    const { status, signal, stdout, stderr } = spawnSync(process.execPath, [fixture], {
+      encoding: 'utf8',
+      timeout: common.platformTimeout(5000),
+    });
+
+    assert.strictEqual(signal, null);
+    assert.strictEqual(status, 0, stderr);
+    assert.match(stdout, /on end/);
+  });
 });
 
 describe('env', () => {