Function scheduleJob

apps/schedules/src/queue.ts:24–51

(job: QueueJob)

};

export const scheduleJob = async (job: QueueJob) => {
	if (job.type === "backup") {
		await jobQueue.add(job.backupId, job, {
			repeat: {
				pattern: job.cronSchedule,
			},
		});
	} else if (job.type === "server") {
		await jobQueue.add(`${job.serverId}-cleanup`, job, {
			repeat: {
				pattern: job.cronSchedule,
			},
		});
	} else if (job.type === "schedule") {
		await jobQueue.add(job.scheduleId, job, {
			repeat: {
				pattern: job.cronSchedule,
				tz: job.timezone || "UTC",
			},
		});
	} else if (job.type === "volume-backup") {
		await jobQueue.add(job.volumeBackupId, job, {
			repeat: {
				pattern: job.cronSchedule,
			},
		});
	}
};

export const removeJob = async (data: QueueJob) => {
	if (data.type === "backup") {