-
Notifications
You must be signed in to change notification settings - Fork 108
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
CUMULUS-3940 -- Forward port to main #3878
base: master
Are you sure you want to change the base?
Conversation
This commit updates the following: - esClient is properly passed through api lambda/lib methods such that write granules calls from process-s3-dead-letter-archive can pass in an instance of EsClient rather than relying on default per-granule object/client behavior - The API endpoint and related code are updated such that maxDbPool, concurrency and batchSize are exposed as endpoint options, allowing user customization of tuning behavior for the DLA recovery tool - Minor typing/call fixes
This commit updates: - archive/cumulus/example to pass through memory configuration options to the fargate task definition
const asyncOperation = await asyncOperations.startAsyncOperation({ | ||
cluster: process.env.EcsCluster, | ||
callerLambdaName: getFunctionNameFromRequestContext(req), | ||
lambdaName: process.env.DeadLetterProcessingLambda, | ||
asyncOperationTaskDefinition: process.env.AsyncOperationTaskDefinition, | ||
asyncOperationTaskDefinition: process.env.DeadLetterRecoveryTaskDefinition, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
so this is our async task definition but using "not the same definition as general async operations" right?
path, | ||
}, | ||
stackName, | ||
systemBucket, | ||
knexConfig: process.env, | ||
knexConfig: { ...process.env, maxDbPool }, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
why isn't maxDbPool being gotten originally from the environment? I note that further down in tests it's being configured as an environment variable
cumulusMessage, | ||
collectionCumulusId, | ||
providerCumulusId, | ||
knex, | ||
executionCumulusId, | ||
esClient, | ||
}); | ||
|
||
return writeGranulesFromMessage({ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
are we certain this works? I don't see a change to "writeGranulesFromMessage" that uses an esclient argument, either In the changes here or in the master branch code
Summary: Summary of changes
Addresses CUMULUS-3940
Changes
Forward port of #3877 - see discussion in port
PR Checklist