Skip to content

Commit de2d828

Browse files
committed
feat: modify worker to handle manual run
1 parent 302ccd1 commit de2d828

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

server/src/worker.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ import { Queue, Worker } from 'bullmq';
22
import IORedis from 'ioredis';
33
import logger from './logger';
44
import { handleRunRecording as handleScheduledRunRecording } from "./workflow-management/scheduler";
5-
import { handleRunRecording } from './api/record';
5+
import { handleRunRecording } from './workflow-management/record';
66
import Robot from './models/Robot';
77
import { computeNextRun } from './utils/schedule';
88

@@ -27,7 +27,7 @@ const worker = new Worker('workflow', async job => {
2727
try {
2828
const result = isScheduled ?
2929
await handleScheduledRunRecording(id, userId) :
30-
await handleRunRecording(id, userId);
30+
await handleRunRecording(id, userId, runId);
3131
return result;
3232
} catch (error) {
3333
logger.error('Error running workflow:', error);

0 commit comments

Comments
 (0)