Comparing version 7.1.0-awsv3 to 7.1.1-awsv3
@@ -16,2 +16,3 @@ /// <reference types="node" /> | ||
messages: Record<string, (worker: Worker, m: any) => void>; | ||
private onExit; | ||
constructor(id: string, task: any, numThreads: any, workerData: any, messages?: Record<string, (worker: Worker, m: any) => void>); | ||
@@ -18,0 +19,0 @@ addNewWorker(workerData: any): void; |
@@ -46,8 +46,7 @@ "use strict"; | ||
this.setMaxListeners(0); //(numThreads * 10); | ||
process.on('SIGINT', () => { | ||
this.onExit = () => { | ||
this.close(); | ||
}); | ||
process.on('exit', () => { | ||
this.close(); | ||
}); | ||
}; | ||
process.on('SIGINT', this.onExit); | ||
process.on('exit', this.onExit); | ||
} | ||
@@ -128,2 +127,5 @@ addNewWorker(workerData) { | ||
async close() { | ||
// Remove event listeners to prevent memory leaks | ||
process.removeListener('SIGINT', this.onExit); | ||
process.removeListener('exit', this.onExit); | ||
if (this.workers.length > 0) { | ||
@@ -130,0 +132,0 @@ //console.log(this.id, "Worker Pool Closing", this.workers.length); |
{ | ||
"name": "leo-sdk", | ||
"version": "7.1.0-awsv3", | ||
"version": "7.1.1-awsv3", | ||
"description": "Load data onto the LEO Platform", | ||
@@ -52,12 +52,12 @@ "homepage": "https://leoplatform.io", | ||
"devDependencies": { | ||
"@aws-sdk/client-cloudformation": "^3.503.1", | ||
"@aws-sdk/client-dynamodb": "^3.503.1", | ||
"@aws-sdk/client-firehose": "^3.503.1", | ||
"@aws-sdk/client-kinesis": "^3.503.1", | ||
"@aws-sdk/client-s3": "^3.503.1", | ||
"@aws-sdk/client-secrets-manager": "^3.503.1", | ||
"@aws-sdk/client-sts": "^3.502.0", | ||
"@aws-sdk/credential-providers": "^3.503.1", | ||
"@aws-sdk/lib-dynamodb": "^3.503.1", | ||
"@aws-sdk/lib-storage": "^3.503.1", | ||
"@aws-sdk/client-cloudformation": "^3.504.0", | ||
"@aws-sdk/client-dynamodb": "^3.504.0", | ||
"@aws-sdk/client-firehose": "^3.504.0", | ||
"@aws-sdk/client-kinesis": "^3.504.0", | ||
"@aws-sdk/client-s3": "^3.504.0", | ||
"@aws-sdk/client-secrets-manager": "^3.504.0", | ||
"@aws-sdk/client-sts": "^3.504.0", | ||
"@aws-sdk/credential-providers": "^3.504.0", | ||
"@aws-sdk/lib-dynamodb": "^3.504.0", | ||
"@aws-sdk/lib-storage": "^3.504.0", | ||
"@aws-sdk/node-http-handler": "^3.374.0", | ||
@@ -74,3 +74,3 @@ "@types/aws-lambda": "^8.10.93", | ||
"@typescript-eslint/parser": "^5.20.0", | ||
"aws-sdk": "^2.1547.0", | ||
"aws-sdk": "^2.1548.0", | ||
"chai": "^4.2.0", | ||
@@ -77,0 +77,0 @@ "cross-env": "^7.0.3", |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
1161012
22751