Dokploy/dokploy
1
0
Fork 0
mirror of https://github.com/Dokploy/dokploy.git synced 2026-06-15 20:25:23 +02:00
Code Issues Packages Projects Releases Wiki Activity

chore: biome

Browse Source
This commit is contained in:
Mauricio Siu
2024-10-07 01:05:47 -06:00
parent 2b0e009f6a
commit ab5871add7
5 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
apps/schedules/src/index.ts
View File

@@ -5,8 +5,8 @@ import { zValidator } from "@hono/zod-validator";
import { logger } from "./logger";
import { cleanQueue, getJobRepeatable, removeJob, scheduleJob } from "./queue";
import { jobQueueSchema } from "./schema";
import { firstWorker, secondWorker } from "./workers";
import { initializeJobs } from "./utils";
import { firstWorker, secondWorker } from "./workers";
const app = new Hono();

2
apps/schedules/src/queue.ts
View File

@@ -1,7 +1,7 @@
import { Queue, type RepeatableJob } from "bullmq";
import IORedis from "ioredis";
import { logger } from "./logger";
import type { QueueJob } from "./schema";
import IORedis from "ioredis";
export const connection = new IORedis(process.env.REDIS_URL || "", {
maxRetriesPerRequest: null,

4
apps/schedules/src/utils.ts
View File

@@ -9,11 +9,11 @@ import {
runPostgresBackup,
} from "@dokploy/server";
import { db } from "@dokploy/server/dist/db";
import { backups, server } from "@dokploy/server/dist/db/schema";
import { eq } from "drizzle-orm";
import { logger } from "./logger";
import type { QueueJob } from "./schema";
import { scheduleJob } from "./queue";
import { backups, server } from "@dokploy/server/dist/db/schema";
import type { QueueJob } from "./schema";
export const runJobs = async (job: QueueJob) => {
try {

4
apps/schedules/src/workers.ts
View File

@@ -1,8 +1,8 @@
import { type Job, Worker } from "bullmq";
import { logger } from "./logger";
import { connection } from "./queue";
import type { QueueJob } from "./schema";
import { runJobs } from "./utils";
import { connection } from "./queue";
import { logger } from "./logger";
export const firstWorker = new Worker(
"backupQueue",