|
| 1 | +import { stringifyIO } from "@trigger.dev/core/v3"; |
1 | 2 | import { type PrismaClientOrTransaction } from "~/db.server"; |
2 | | -import { BaseService } from "./baseService.server"; |
| 3 | +import { devPresence } from "~/presenters/v3/DevPresence.server"; |
| 4 | +import { logger } from "~/services/logger.server"; |
3 | 5 | import { workerQueue } from "~/services/worker.server"; |
| 6 | +import { findCurrentWorkerDeployment } from "../models/workerDeployment.server"; |
| 7 | +import { nextScheduledTimestamps } from "../utils/calculateNextSchedule.server"; |
| 8 | +import { BaseService } from "./baseService.server"; |
4 | 9 | import { RegisterNextTaskScheduleInstanceService } from "./registerNextTaskScheduleInstance.server"; |
5 | 10 | import { TriggerTaskService } from "./triggerTask.server"; |
6 | | -import { stringifyIO } from "@trigger.dev/core/v3"; |
7 | | -import { nextScheduledTimestamps } from "../utils/calculateNextSchedule.server"; |
8 | | -import { findCurrentWorkerDeployment } from "../models/workerDeployment.server"; |
9 | | -import { logger } from "~/services/logger.server"; |
10 | | -import { env } from "~/env.server"; |
11 | | -import Redis from "ioredis"; |
12 | | -import { devPresence, DevPresence } from "~/presenters/v3/DevPresence.server"; |
13 | | - |
14 | | -const redis = new Redis({ |
15 | | - port: env.RUN_ENGINE_DEV_PRESENCE_REDIS_PORT ?? undefined, |
16 | | - host: env.RUN_ENGINE_DEV_PRESENCE_REDIS_HOST ?? undefined, |
17 | | - username: env.RUN_ENGINE_DEV_PRESENCE_REDIS_USERNAME ?? undefined, |
18 | | - password: env.RUN_ENGINE_DEV_PRESENCE_REDIS_PASSWORD ?? undefined, |
19 | | - enableAutoPipelining: true, |
20 | | - ...(env.RUN_ENGINE_DEV_PRESENCE_REDIS_TLS_DISABLED === "true" ? {} : { tls: {} }), |
21 | | -}); |
22 | 11 |
|
23 | 12 | export class TriggerScheduledTaskService extends BaseService { |
24 | 13 | public async call(instanceId: string, finalAttempt: boolean) { |
|
0 commit comments