Function exitHandler

apps/worker/src/boot-workers.ts:327–384

(
    eventName: string,
    evtOrExitCodeOrError: number | string | Error
  )

  });

  async function exitHandler(
    eventName: string,
    evtOrExitCodeOrError: number | string | Error
  ) {
    logger.info(
      { code: evtOrExitCodeOrError, eventName },
      'Starting graceful shutdown'
    );

    // Hard deadline: if cron drain or worker.close() hangs, force-exit
    // before Docker's stop_grace_period elapses. Without this the
    // container sits in "Stopping" until SIGKILL (exit 137) and looks
    // like a real crash to the swarm.
    const forceExitMs = Number(
      process.env.SHUTDOWN_FORCE_EXIT_MS || '20000'
    );
    const exitCode = Number.isNaN(+evtOrExitCodeOrError)
      ? 1
      : +evtOrExitCodeOrError;
    const forceExit = setTimeout(() => {
      logger.error(
        { eventName, forceExitMs },
        'Graceful shutdown timed out — forcing exit'
      );
      process.exit(exitCode);
    }, forceExitMs);
    forceExit.unref();

    try {
      const time = performance.now();

      // Wait for cron queue to empty if it's running
      if (enabledQueues.includes('cron')) {
        await waitForQueueToEmpty(cronQueue);
      }

      await Promise.all([
        ...workers.map((worker) => worker.close()),
        ...extraStops.map((stop) =>
          stop().catch((err) => {
            logger.error({ err }, 'extra stop handler error');
          })
        ),
      ]);

      logger.info(
        { elapsed: performance.now() - time },
        'workers closed successfully'
      );
    } catch (e) {
      logger.error(
        { err: e, code: evtOrExitCodeOrError },
        'exit handler error'
      );
    }
    clearTimeout(forceExit);
    process.exit(exitCode);
  }