Skip to content

Commit

Permalink
Fix material test tool bug (#2520)
Browse files Browse the repository at this point in the history
* Fix: Add Log to fin why ws stop

Add Log to fin why ws stop

* Fix: Add Log to fin why ws stop

Add Log to fin why ws stop
  • Loading branch information
leo-songye-li authored Nov 6, 2024
1 parent 6f1ddc4 commit 0ab3da8
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions src/server/services/task-manager/TaskManager.ts
Original file line number Diff line number Diff line change
Expand Up @@ -49,15 +49,20 @@ class TaskManager {
private tasks: Task[] = [];

private exec(runnerName: string, task: Task) {
log.info(`workmanager:exec:${runnerName}`);
const { terminate } = this.workerManager[runnerName]([task.data], (payload) => {
if (payload.status === 'progress') {
log.info(`workmanager:status:${payload.status}`);
this.onProgress(task, payload.value);
} else if (payload.status === 'complete') {
log.info(`workmanager:status:${payload.status}`);
this.onComplete(task, payload.value);
} else if (payload.status === 'fail') {
log.info(`workmanager:status:${payload.status}`);
this.onFail(task, payload.value);
}
});
log.info(`workmanager:exec:term:${terminate}`);
task.terminateFn = terminate;
}

Expand Down Expand Up @@ -143,6 +148,7 @@ class TaskManager {

const runnerName = TASK_TYPE_RUNNER_MAP[task.taskType];
if (runnerName) {
log.info(`runnername:${runnerName}`);
this.exec(runnerName, task);
} else {
log.warn(`task runner for ${task.taskType} no found`);
Expand Down

0 comments on commit 0ab3da8

Please sign in to comment.