@@ -4,7 +4,7 @@ import { relative } from 'node:path'
 import { Writable } from 'node:stream'
 import { getSafeTimers } from '@vitest/utils/timers'
 import c from 'tinyrainbow'
-import { getWorkerState } from './utils'
+import { EnvironmentTeardownError, getWorkerState } from './utils'
 
 const RealDate = globalThis.Date
 
@@ -109,14 +109,21 @@ export function createCustomConsole(defaultState?: WorkerGlobalState): Console {
   ) {
     const timer = timers.get(taskId)!
     const time = type === 'stderr' ? timer.stderrTime : timer.stdoutTime
-    state().rpc.onUserConsoleLog({
-      type,
-      content: content || '<empty line>',
-      taskId,
-      time: time || RealDate.now(),
-      size,
-      origin,
-    })
+    state()
+      .rpc.onUserConsoleLog({
+        type,
+        content: content || '<empty line>',
+        taskId,
+        time: time || RealDate.now(),
+        size,
+        origin,
+      })
+      .catch((error) => {
+        // the log is already sent, the worker only closed before the reporter answered
+        if (!(error instanceof EnvironmentTeardownError)) {
+          throw error
+        }
+      })
   }
 
   const stdout = new Writable({
 
@@ -1,7 +1,7 @@
 import { relative, resolve } from 'pathe'
 import { expect, test } from 'vitest'
 import { DefaultReporter } from 'vitest/node'
-import { runInlineTests, runVitest } from '../../test-utils'
+import { runInlineTests, runVitest, ts } from '../../test-utils'
 
 test('can run custom pools with Vitest', async () => {
   const reporter = new DefaultReporter()
@@ -152,3 +152,45 @@ test('onConsoleLog receives the entity', async () => {
     ]
   `)
 })
+
+// https://github.com/vitest-dev/vitest/issues/11153
+test('console log sent while the worker closes is not reported as an error', async () => {
+  const { stderr, testTree } = await runInlineTests(
+    {
+      'late-log.test.ts': ts`
+      import { test } from 'vitest'
+
+      test('logs and leaks an interval', () => {
+        console.log('log inside the test')
+        let ticks = 0
+        const interval = setInterval(() => {
+          console.log('log after the test')
+          if (++ticks === 50) {
+            clearInterval(interval)
+          }
+        }, 2)
+      })
+    `,
+    },
+    {
+      reporters: [
+        'verbose',
+        {
+          async onUserConsoleLog() {
+            // keep every log pending, so the worker closes while the late logs wait for an answer
+            await new Promise((resolve) => setTimeout(resolve, 20))
+          },
+        },
+      ],
+    },
+  )
+
+  expect(stderr).toBe('')
+  expect(testTree()).toMatchInlineSnapshot(`
+    {
+      "late-log.test.ts": {
+        "logs and leaks an interval": "passed",
+      },
+    }
+  `)
+})