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
209
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.0
to
3.9.1
+1
-1
package.json

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

},
"version": "3.9.0"
"version": "3.9.1"
}
'use strict';
const logger = require('@emartech/json-logger')('program-executor');
const devLogger = require('@emartech/json-logger')('dev-program-executor');
const RetryableError = require('../retryable-error');

@@ -16,2 +17,3 @@ const JobHandler = require('../job-data-handler');

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

@@ -21,2 +23,5 @@ try {

} catch (error) {
devLogger.error('error in job', { runId, OSPID: process.pid,
error, errorMessage: error.message, errorCode: error.code,
errorRetryable: error.retryable, errorIgnorable: error.ignorable });
if (error.retryable) {

@@ -60,5 +65,7 @@ await this._programHandler.incrementStepRetryCount(runId);

if (remainingJobs.length > 0) {
devLogger.info('queue update remainingJobs', { remainingJobs, 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 });
await this._programHandler.finishProgram(runId);

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

'use strict';
const devLogger = require('@emartech/json-logger')('dev-program-executor');
const RunIdGenerator = require('../runid-generator');

@@ -54,2 +55,3 @@

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

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