Receiving task definition by events

This commit is contained in:
Luis Fernando Molina committed 2019-11-15 08:36:41 +01:00
1 parent e92204b741
commit b5fc0545c7
1 file changed
+9 -2
+9 -2
View File
@@ -54,7 +54,7 @@ function runTask(message) {
let path = process.env.TASK_SERVER_PATH + '/server.js'
/* Workarround to avoid having the same debub port at the forked process which makes it crash. */
/* Workarround to avoid having the same debug port at the forked process which makes it crash. */
for (let i = 0; i < process.execArgv.length; i++) {
let argument = process.execArgv[i]
if (argument.indexOf('--inspect') > -1) {
@@ -64,7 +64,7 @@ function runTask(message) {
/* Forking this process. */
let task = {
childProcess: fork(path , [message.event.definition], { stdio: 'inherit' }),
childProcess: fork(path, [message.event.taskId], { stdio: 'inherit' }),
id: message.event.taskId,
name: message.event.taskName
}
@@ -81,6 +81,13 @@ function runTask(message) {
console.log('[INFO] Task Manager -> server -> runTask -> Task Terminated. -> Task Id = ' + task.id)
tasks.delete(task.id)
})
setTimeout(sendStartingEvent, 1000)
function sendStartingEvent() {
console.log('[INFO] Task Manager -> server -> runTask -> Emitting Event -> key = ' + 'Task Server - ' + task.id)
global.SYSTEM_EVENT_HANDLER.raiseEvent('Task Server - ' + task.id, 'Run Task', message.event)
}
}
function stopTask(message) {