vodorod/parcer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: rename runWorkflow to createWorkflowAndStoreMetadata

Browse Source
This commit is contained in:
karishmas6
2024-10-12 15:44:22 +05:30
parent 757e71680f
commit fd32432334
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server/src/workflow-management/scheduler/index.ts
View File

@@ -9,7 +9,7 @@ import Robot from "../../models/Robot";
import Run from "../../models/Run"; import Run from "../../models/Run";
import { getDecryptedProxyConfig } from "../../routes/proxy"; import { getDecryptedProxyConfig } from "../../routes/proxy";
async function runWorkflow(id: string, userId: string) { async function createWorkflowAndStoreMetadata(id: string, userId: string) {
if (!id) { if (!id) {
id = uuid(); id = uuid();
} }
@@ -171,7 +171,7 @@ function resetRecordingState(browserId: string, id: string) {
export async function handleRunRecording(id: string, userId: string) { export async function handleRunRecording(id: string, userId: string) {
try { try {
const result = await runWorkflow(id, userId); const result = await createWorkflowAndStoreMetadata(id, userId);
const { browserId, runId: newRunId } = result; const { browserId, runId: newRunId } = result;
if (!browserId || !newRunId || !userId) { if (!browserId || !newRunId || !userId) {
@@ -201,4 +201,4 @@ function cleanupSocketListeners(socket: Socket, browserId: string, id: string) {
logger.log('info', `Cleaned up listeners for browserId: ${browserId}, runId: ${id}`); logger.log('info', `Cleaned up listeners for browserId: ${browserId}, runId: ${id}`);
} }
export { runWorkflow }; export { createWorkflowAndStoreMetadata };