diff --git a/lib/actions/policySettings.ts b/lib/actions/policySettings.ts index 245126f..04404a1 100644 --- a/lib/actions/policySettings.ts +++ b/lib/actions/policySettings.ts @@ -5,7 +5,6 @@ import { getUserAuth } from '@/lib/auth/utils'; import { eq, ilike, or, desc, and, ne, isNotNull } from 'drizzle-orm'; import { env } from '@/lib/env.mjs'; import { syncQueue } from '@/lib/queue/syncQueue'; -import { syncQueue } from '@/lib/queue/syncQueue'; export interface PolicySettingSearchResult { id: string; diff --git a/worker/Dockerfile b/worker/Dockerfile index 1967fbb..816c91f 100644 --- a/worker/Dockerfile +++ b/worker/Dockerfile @@ -25,7 +25,6 @@ RUN npm ci --production --silent COPY --from=builder /usr/src/app/dist ./dist COPY --from=builder /usr/src/app/worker ./worker COPY --from=builder /usr/src/app/lib ./lib -COPY --from=builder /usr/src/app/.env* ./ || true ENV NODE_ENV=production diff --git a/worker/events.ts b/worker/events.ts index b6e6715..19f8734 100644 --- a/worker/events.ts +++ b/worker/events.ts @@ -5,15 +5,17 @@ const jobStartTimes = new Map(); export function attachWorkerEvents(worker: Worker) { worker.on('active', (job: Job) => { - jobStartTimes.set(job.id, Date.now()); - logger.info({ event: 'job_active', jobId: job.id, name: job.name, data: job.data }); + const jobId = job.id?.toString() || 'unknown'; + jobStartTimes.set(jobId, Date.now()); + logger.info({ event: 'job_active', jobId, name: job.name, data: job.data }); }); worker.on('completed', (job: Job) => { - const start = jobStartTimes.get(job.id) || Date.now(); + const jobId = job.id?.toString() || 'unknown'; + const start = jobStartTimes.get(jobId) || Date.now(); const durationMs = Date.now() - start; - jobStartTimes.delete(job.id); - logger.info({ event: 'job_complete', jobId: job.id, durationMs, timestamp: new Date().toISOString() }); + jobStartTimes.delete(jobId); + logger.info({ event: 'job_complete', jobId, durationMs, timestamp: new Date().toISOString() }); }); worker.on('failed', (job: Job | undefined, err: Error | undefined) => {