This lambda function adds a workflow to a queue
For more information on configuring a Cumulus Message Adapter task, see the Cumulus workflow input/output documentation.
Config object fields:
| field name | type | default | description |
|---|---|---|---|
| internalBucket | string | (required) | S3 bucket |
| parentWorkflow | string | (required) | Parent workflow of the task |
| stackName | string | (required) | Name of deployment stack |
| queueUrl | string | (required) | SQS queue url |
| executionNamePrefix | string | (optional) | the prefix to apply to the name of the enqueued execution |
Input object fields:
| field name | type | default | description |
|---|---|---|---|
| workflow | object | (required) | The workflow to be queued |
| workflowInput | object | (required) | The payload to the workflow to be executed |
| queueUrl | string | (optional) | URL to an SQS queue (e.g. to specify a lower priority queue) |
Output object fields:
| field name | type | default | values | description |
|---|---|---|---|---|
| workflow | object | N/A | The workflow to be queued | |
| workflowInput | object | N/A | The payload to the workflow to be executed | |
| running | string | N/A | The execution arn for queuing the workflow |
Cumulus is a cloud-based data ingest, archive, distribution and management prototype for NASA's future Earth science data streams.
To make a contribution, please see our contributing guidelines.