Skip to content

Commit

Permalink
Update doc, add space
Browse files Browse the repository at this point in the history
  • Loading branch information
msambol committed Nov 19, 2024
1 parent a95dfb8 commit 3c85b5a
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
3 changes: 2 additions & 1 deletion packages/@aws-cdk/aws-pipes-alpha/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,8 @@ A source is a AWS Service that is polled. The following sources are possible:
- [Amazon SQS queue](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-sqs.html)
- [Apache Kafka stream](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-kafka.html)

Currently, DynamoDB, Kinesis, and SQS are supported. Others will be added in the future.
Currently, DynamoDB, Kinesis, and SQS are supported. If you are interested in support for additional sources,
kindly let us know by opening a GitHub issue or raising a PR.

### Example source

Expand Down
4 changes: 2 additions & 2 deletions packages/@aws-cdk/aws-pipes-alpha/test/integ.pipe.ts
Original file line number Diff line number Diff line change
Expand Up @@ -103,9 +103,9 @@ const putMessageOnQueue = test.assertions.awsApiCall('SQS', 'sendMessage', {
putMessageOnQueue.next(test.assertions.awsApiCall('SQS', 'receiveMessage', {
QueueUrl: targetQueue.queueUrl,
})).expect(ExpectedResult.objectLike({
Messages: [{ Body: uniqueIdentifier+ '-' + pipe.pipeName + '-static' }],
Messages: [{ Body: uniqueIdentifier + '-' + pipe.pipeName + '-static' }],
})).waitForAssertions({
totalTimeout: cdk.Duration.minutes(2),
totalTimeout: cdk.Duration.seconds(30),
interval: cdk.Duration.seconds(15),
});

Expand Down

0 comments on commit 3c85b5a

Please sign in to comment.