fix: missing imports
This commit is contained in:
@@ -2,6 +2,8 @@ import { Queue, Worker } from 'bullmq';
|
|||||||
import IORedis from 'ioredis';
|
import IORedis from 'ioredis';
|
||||||
import logger from './logger';
|
import logger from './logger';
|
||||||
import { handleRunRecording } from "./workflow-management/scheduler";
|
import { handleRunRecording } from "./workflow-management/scheduler";
|
||||||
|
import Robot from './models/robot';
|
||||||
|
import { computeNextRun } from './utils/schedule';
|
||||||
|
|
||||||
const connection = new IORedis({
|
const connection = new IORedis({
|
||||||
host: 'localhost',
|
host: 'localhost',
|
||||||
@@ -49,7 +51,6 @@ worker.on('completed', async (job: any) => {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
});
|
|
||||||
|
|
||||||
worker.on('failed', async (job: any, err) => {
|
worker.on('failed', async (job: any, err) => {
|
||||||
logger.log(`error`, `Job ${job.id} failed for ${job.data.runId}:`, err);
|
logger.log(`error`, `Job ${job.id} failed for ${job.data.runId}:`, err);
|
||||||
|
|||||||
Reference in New Issue
Block a user