`Effect.cachedWithTTL` and `Effect.cachedInvalidateWithTTL` suppress triggering of `Effect.timeout`

[MartinRamm]

What version of Effect is running?

3.21.4

What steps can reproduce the bug?

Run the following code:

import { Effect, pipe } from 'effect';

const causeTimeout = pipe(
  Effect.async(() => {}),
  Effect.timeoutFail({
    duration: '1 second',
    onTimeout: () => 'Timeout',
  })
);

await pipe(
  Effect.cachedWithTTL(causeTimeout, '1 minute'),
  Effect.andThen(run => run),
  Effect.runPromiseExit,
  promiseExit => Promise.race([
    promiseExit,
    new Promise((resolve) => setTimeout(() => resolve('Timeout waiting for Exit'), 5_000))
  ]).then(console.log)
);

What is the expected behavior?

A Exit object with failure "Timeout" is printed to the console

What do you see instead?

String "Timeout waiting for Exit" is printed to console

Additional information

It seems like Effect.cachedWithTTL prevents the timeout from being triggered. Interestingly enough, Effect.cached works as expected.

Effect.cachedInvalidateWithTTL also suppresses to trigger the timeout

[MartinRamm]

Out of interest, I investigated the cause of this bug. The problem seems to be the usage of Effect.uninterruptibleMask in Circular.getCachedValue.

Timeouts seem to be considered an interruption, which Effect.uninterruptibleMask and Effect.uninterruptible suppress - see the following code, which prints "Timeout waiting for Exit" to the console

await pipe(
  causeTimeout,
  Effect.uninterruptible,
  Effect.runPromiseExit,
  promiseExit => Promise.race([
    promiseExit,
    new Promise((resolve) => setTimeout(() => resolve('Timeout waiting for Exit'), 5_000))
  ]).then(console.log)
);

While I would consider Effect.uninterruptible* suppressing the timeout to make sense, the usage of this function inside Effect.uninterruptibleMask is not intuitive at all. It may be worth investigating what other functions are effected by this problem.

[MartinRamm]

Workaround: explicitly mark the effect to be cashed as interruptable before giving it to cachedWithTTL:

await pipe(
  causeTimeout,
  Effect.interruptible,
  Effect.cachedWithTTL('1 minute'),
  Effect.andThen(run => run),
  Effect.runPromiseExit,
  promiseExit => Promise.race([
    promiseExit,
    new Promise((resolve) => setTimeout(() => resolve('Timeout waiting for Exit'), 5_000))
  ]).then(console.log)
);