Big News: Socket raises $60M Series C at a $1B valuation to secure software supply chains for AI-driven development.Announcement
Sign In

@emartech/program-executor

Package Overview
Dependencies
Maintainers
212
Versions
58
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@emartech/program-executor - npm Package Compare versions

Comparing version
3.9.2
to
3.9.3
+1
-1
package.json

@@ -45,3 +45,3 @@ {

},
"version": "3.9.2"
"version": "3.9.3"
}

@@ -17,3 +17,3 @@ 'use strict';

const { runId } = message;
devLogger.info('new job from queue', { runId, OSPID: process.pid });
devLogger.info('new job from queue', { run_id: runId, OSPID: process.pid });

@@ -23,3 +23,3 @@ try {

} catch (error) {
devLogger.error('error in job', { runId, OSPID: process.pid,
devLogger.error('error in job', { run_id: runId, OSPID: process.pid,
error, errorMessage: error.message, errorCode: error.code,

@@ -65,7 +65,7 @@ errorRetryable: error.retryable, errorIgnorable: error.ignorable });

if (remainingJobs.length > 0) {
devLogger.info('queue update remainingJobs', { remainingJobs, runId, OSPID: process.pid });
devLogger.info('queue update remainingJobs', { remainingJobs, run_id: runId, OSPID: process.pid });
await this._queueManager.queueProgram({ ...message, jobs: remainingJobs });
await this._programHandler.incrementStep(runId);
} else {
devLogger.info('finished program', { runId, OSPID: process.pid });
devLogger.info('finished program', { run_id: runId, OSPID: process.pid });
await this._programHandler.finishProgram(runId);

@@ -72,0 +72,0 @@ }

@@ -55,3 +55,3 @@ 'use strict';

devLogger.info('db update job data', { runId, jobName, payload, merge, OSPID: process.pid });
devLogger.info('db update job data', { run_id: runId, jobName, payload: JSON.stringify(payload), merge, OSPID: process.pid });
return this._programsRepository.setJobDataByRunId(runId, jobData);

@@ -58,0 +58,0 @@ }