import { getBoss } from "../../workert";
import { WorkerQueue } from "./queues";

/**
 * Enqueue a single incremental sync job via PgBoss.
 * Called on an interval from the main API process so it survives worker restarts.
 */
export async function enqueueIncrementalSync(): Promise<void> {
  await getBoss().send(WorkerQueue.DALPURI_INCREMENTAL_SYNC, {});
}
