@emartech/program-executor
Advanced tools
+1
-1
@@ -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 @@ } |
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
Found 2 instances in 1 package
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
Found 2 instances in 1 package
82541
0.86%1709
0.53%