update rosetta

Author: msambol

packages/@aws-cdk/aws-pipes-sources-alpha/README.md

@@ -66,8 +66,6 @@ const pipe = new pipes.Pipe(this, 'Pipe', {
 A Kinesis stream can be used as a source for a pipe. The stream will be polled for new messages and the messages will be sent to the pipe.
 
 ```ts
-import * as kinesis from 'aws-cdk-lib/aws-kinesis';
-
 declare const sourceStream: kinesis.Stream;
 declare const targetQueue: sqs.Queue;
 
@@ -86,8 +84,6 @@ const pipe = new pipes.Pipe(this, 'Pipe', {
 A DynamoDB stream can be used as a source for a pipe. The stream will be polled for new messages and the messages will be sent to the pipe.
 
 ```ts
-import * as ddb from 'aws-cdk-lib/aws-dynamodb';
-
 const table = new ddb.TableV2(stack, 'MyTable', {
   partitionKey: {
     name: 'id',

packages/@aws-cdk/aws-pipes-sources-alpha/lib/dynamodb.ts

@@ -1,7 +1,7 @@
 import { IPipe, ISource, SourceConfig } from '@aws-cdk/aws-pipes-alpha';
 import { Duration } from 'aws-cdk-lib';
-import { IRole } from 'aws-cdk-lib/aws-iam';
 import { ITableV2 } from 'aws-cdk-lib/aws-dynamodb';
+import { IRole } from 'aws-cdk-lib/aws-iam';
 import { DeadLetterConfigParameters } from './deadLetterConfig';
 import { DynamoDBStartingPosition, OnPartialBatchItemFailure } from './enums';
 

packages/@aws-cdk/aws-pipes-sources-alpha/rosetta/default.ts-fixture

@@ -1,6 +1,8 @@
 // Fixture with packages imported, but nothing else
 import * as cdk from 'aws-cdk-lib';
 import * as sqs from 'aws-cdk-lib/aws-sqs';
+import * as kinesis from 'aws-cdk-lib/aws-kinesis';
+import * as ddb from 'aws-cdk-lib/aws-dynamodb';
 import { Construct } from 'constructs';
 import * as pipes from '@aws-cdk/aws-pipes-alpha';
 import * as sources from '@aws-cdk/aws-pipes-sources-alpha';

packages/@aws-cdk/aws-pipes-sources-alpha/test/integ.dynamodb.ts

@@ -61,8 +61,8 @@ const message = test.assertions.awsApiCall('SQS', 'receiveMessage', {
   QueueUrl: targetQueue.queueUrl,
 });
 
-message.assertAtPath('Messages.0.Body.dynamodb.Keys.id.S', ExpectedResult.exact('1')).waitForAssertions({
-  totalTimeout: cdk.Duration.minutes(3),
+message.assertAtPath('Messages.0.Body.dynamodb.Keys.id.S', ExpectedResult.stringLikeRegexp('"1"')).waitForAssertions({
+  totalTimeout: cdk.Duration.minutes(2),
   interval: cdk.Duration.seconds(15),
 });