diff --git a/fluxer_api/src/api/worker/WorkerHeartbeat.ts b/fluxer_api/src/api/worker/WorkerHeartbeat.ts index 3b13b54d8..b2958da46 100644 --- a/fluxer_api/src/api/worker/WorkerHeartbeat.ts +++ b/fluxer_api/src/api/worker/WorkerHeartbeat.ts @@ -3,9 +3,8 @@ import {writeFileSync} from 'node:fs'; import type {ILogger} from '../ILogger'; -export const WORKER_HEARTBEAT_PATH = '/tmp/fluxer-worker-heartbeat'; +const WORKER_HEARTBEAT_PATH = '/tmp/fluxer-worker-heartbeat'; export const WORKER_HEARTBEAT_WRITE_INTERVAL_MS = 5000; -export const WORKER_HEARTBEAT_MAX_AGE_MS = 30000; export const WORKER_LANE_HEARTBEAT_INTERVAL_MS = 5000; export const WORKER_LANE_STALE_AFTER_MS = 30000; export const WORKER_CRON_STALE_AFTER_MS = 90000; diff --git a/fluxer_api/src/api/worker/WorkerProcessErrorHandler.ts b/fluxer_api/src/api/worker/WorkerProcessErrorHandler.ts index e64837d8a..9a660759b 100644 --- a/fluxer_api/src/api/worker/WorkerProcessErrorHandler.ts +++ b/fluxer_api/src/api/worker/WorkerProcessErrorHandler.ts @@ -6,7 +6,7 @@ import type {ILogger} from '../ILogger'; export type WorkerProcessErrorSource = 'uncaughtException' | 'unhandledRejection'; -export type WorkerProcessErrorHandler = (source: WorkerProcessErrorSource, error: unknown) => Promise; +type WorkerProcessErrorHandler = (source: WorkerProcessErrorSource, error: unknown) => Promise; interface WorkerProcessErrorHandlerOptions { logger: Pick;