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
283
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.12.1
to
3.13.0
+8
.github/workflows/dependabot-random-reviewer-poker.yml
name: Dependabot Reviewer Poker
on:
pull_request:
types: [opened, reopened]
jobs:
assign-random-reviewer:
uses: Emartech/IntegrationCloud-DevOps-Workstream/.github/workflows/dependabot-random-review-poker.yml@main
secrets: inherit
+2
-2

@@ -22,3 +22,3 @@ {

"dependencies": {
"@emartech/json-logger": "3.4.0",
"@emartech/json-logger": "9.1.0",
"@emartech/pubsub-client-js": "^1.2.7",

@@ -43,3 +43,3 @@ "@emartech/rabbitmq-client": "5.9.1",

},
"version": "3.12.1"
"version": "3.13.0"
}
'use strict';
const logger = require('@emartech/json-logger')('program-executor');
const devLogger = require('@emartech/json-logger')('dev-program-executor');
const { createLogger } = require('@emartech/json-logger');
createLogger.configure({
outputFormat: 'legacy'
});
const logger = createLogger('program-executor');
const devLogger = createLogger('dev-program-executor');
const RetryableError = require('../retryable-error');

@@ -22,5 +27,7 @@ const JobHandler = require('../job-data-handler');

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

@@ -75,4 +82,6 @@ await this._programHandler.incrementStepRetryCount(runId);

logger[level](action,
{ customer_id: programData.customerId, run_id: runId, OSPID: process.pid, msg: currentJob,
executor: { current_job: currentJob, program_data: programData, jobs } });
{
customer_id: programData.customerId, run_id: runId, OSPID: process.pid, msg: currentJob,
executor: { current_job: currentJob, program_data: programData, jobs }
});
}

@@ -79,0 +88,0 @@

'use strict';
const devLogger = require('@emartech/json-logger')('dev-program-executor');
const { createLogger } = require('@emartech/json-logger');
createLogger.configure({
outputFormat: 'legacy'
});
const devLogger = createLogger('dev-program-executor');
const RunIdGenerator = require('../runid-generator');

@@ -5,0 +10,0 @@

'use strict';
const PubSubClient = require('@emartech/pubsub-client-js').PubSubClient;
const logger = require('@emartech/json-logger')('program-executor-queue-manager-pubsub');
const { createLogger } = require('@emartech/json-logger');
createLogger.configure({
outputFormat: 'legacy'
});
const logger = createLogger('program-executor-queue-manager-pubsub');
class QueueManager {

@@ -7,0 +12,0 @@ constructor(topicName, projectId, gcpKeyFileName) {

'use strict';
const RabbitMq = require('@emartech/rabbitmq-client').RabbitMq;
const logger = require('@emartech/json-logger')('program-executor-queue-manager');
const { createLogger } = require('@emartech/json-logger');
createLogger.configure({
outputFormat: 'legacy'
});
const logger = createLogger('program-executor-queue-manager');
class QueueManager {

@@ -7,0 +12,0 @@ constructor(amqpUrl, queueName) {