TimeoutOverflowWarning

[alexbouttier]

Description

I’m using pulse.schedule with dates that are more than 24 days from the current date, and I’m getting this error:
TimeoutOverflowWarning: 2494793808 does not fit into a 32-bit signed integer.
How can I avoid this error, since it’s common to want to schedule tasks far in the future?

Code example

No response

Additional context

No response

[lc3t35]

Here is the related code that uses setTimeout

pulse/src/utils/process-jobs.ts

Line 244 in a2e0202

// Otherwise, setTimeout that gets called at the time of 'nextRunAt'

if (!job.attrs.nextRunAt || job.attrs.nextRunAt <= now) {
      debug('[%s:%s] nextRunAt is in the past, run the job immediately', job.attrs.name, job.attrs._id);
      runOrRetry();
    } else {
      // @ts-expect-error linter complains about Date-arithmetic
      const runIn = job.attrs.nextRunAt - now;
      debug('[%s:%s] nextRunAt is in the future, calling setTimeout(%d)', job.attrs.name, job.attrs._id, runIn);
      setTimeout(jobProcessing, runIn);
    }

It should verify that runin is not bigger than 2 147 483 647 (biggest 32-bit signed integer)

You can update code this way :

      const MAX_TIMEOUT = Math.pow(2, 31) - 1;
      if (runIn > MAX_TIMEOUT) {
        // For jobs scheduled beyond the setTimeout limit, use a shorter timeout and re-check periodically
        const checkInterval = Math.min(MAX_TIMEOUT, 24 * 60 * 60 * 1000); // Check every 24 hours or at the limit
        debug('[%s:%s] nextRunAt exceeds setTimeout limit (%d > %d), scheduling periodic check in %d ms',
              job.attrs.name, job.attrs._id, runIn, MAX_TIMEOUT, checkInterval);
        setTimeout(() => {
          // Re-enqueue the job for processing, which will re-evaluate the timing
          enqueueJobs(job);
        }, checkInterval);
      } else {
        debug('[%s:%s] nextRunAt is in the future, calling setTimeout(%d)', job.attrs.name, job.attrs._id, runIn);
        setTimeout(jobProcessing, runIn);
      }
    }

[linaia]

Here is the pull request to fix the issue