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

feat: !execute workflow

Browse Source
This commit is contained in:
karishmas6
2024-09-12 19:37:20 +05:30
parent 76f7959630
commit a4dd08b814
1 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -4,7 +4,7 @@ import { deleteFile, readFile, readFiles, saveFile } from "../storage";
import { createRemoteBrowserForRun, destroyRemoteBrowser, getActiveBrowserId } from '../../browser-management/controller'; import { createRemoteBrowserForRun, destroyRemoteBrowser, getActiveBrowserId } from '../../browser-management/controller';
import { RemoteBrowser } from '../../browser-management/classes/RemoteBrowser'; import { RemoteBrowser } from '../../browser-management/classes/RemoteBrowser';
import logger from '../../logger'; import logger from '../../logger';
import { browserPool } from "../../server"; import { browserPool, io } from "../../server";
import fs from "fs"; import fs from "fs";
import { uuid } from "uuidv4"; import { uuid } from "uuidv4";
import { chromium } from "playwright"; import { chromium } from "playwright";
@@ -61,7 +61,6 @@ async function runWorkflow(fileName: string, runId: string) {
runId = uuid(); runId = uuid();
} }
// Phase 1: Scheduling
try { try {
const browserId = createRemoteBrowserForRun({ const browserId = createRemoteBrowserForRun({
browser: chromium, browser: chromium,
@@ -88,9 +87,6 @@ async function runWorkflow(fileName: string, runId: string) {
logger.log('debug', `Scheduled run with name: ${fileName}_${runId}.json`); logger.log('debug', `Scheduled run with name: ${fileName}_${runId}.json`);
// Phase 2: Running
return await executeRun(fileName, runId);
} catch (e) { } catch (e) {
const { message } = e as Error; const { message } = e as Error;
logger.log('info', `Error while scheduling a run with name: ${fileName}_${runId}.json`); logger.log('info', `Error while scheduling a run with name: ${fileName}_${runId}.json`);