Assist_Design/apps/bff/src/modules/jobs/reconcile.processor.ts

import { Processor, WorkerHost } from "@nestjs/bullmq";
import { Logger } from "@nestjs/common";
import { Job } from "bullmq";
import { QUEUE_NAMES } from "@bff/infra/queue/queue.constants";

@Processor(QUEUE_NAMES.RECONCILE)
export class ReconcileProcessor extends WorkerHost {
  private readonly logger = new Logger(ReconcileProcessor.name);

  async process(job: Job) {
    this.logger.warn(
      `Skipping reconciliation job while JobsModule is temporarily disabled`,
      {
        jobId: job.id,
        name: job.name,
        attemptsMade: job.attemptsMade,
      },
    );

    return { status: "skipped", reason: "jobs_module_disabled" };
  }
}