chore(pipes-targets): update integration tests to use SqsSource (#31588)

This incorporates feedback from #30756 so all integration tests are uniform. Related to #31589.
aws · Oct 8, 2024 · b766a83 · b766a83
1 parent 17b12f2
commit b766a83
Show file tree

Hide file tree

Showing 30 changed files with 3,623 additions and 4,227 deletions.
diff --git a/packages/@aws-cdk/aws-pipes-targets-alpha/README.md b/packages/@aws-cdk/aws-pipes-targets-alpha/README.md
@@ -47,7 +47,7 @@ declare const targetQueue: sqs.Queue;
 const pipeTarget = new targets.SqsTarget(targetQueue);
 
 const pipe = new pipes.Pipe(this, 'Pipe', {
-    source: new SomeSource(sourceQueue),
+    source: new SqsSource(sourceQueue),
     target: pipeTarget
 });
 ```
@@ -68,7 +68,7 @@ const pipeTarget = new targets.SqsTarget(targetQueue,
 );
 
 const pipe = new pipes.Pipe(this, 'Pipe', {
-    source: new SomeSource(sourceQueue),
+    source: new SqsSource(sourceQueue),
     target: pipeTarget
 });
 ```
@@ -84,7 +84,7 @@ declare const targetStateMachine: sfn.IStateMachine;
 const pipeTarget = new targets.SfnStateMachine(targetStateMachine,{});
 
 const pipe = new pipes.Pipe(this, 'Pipe', {
-    source: new SomeSource(sourceQueue),
+    source: new SqsSource(sourceQueue),
     target: pipeTarget
 });
 ```
@@ -102,7 +102,7 @@ const pipeTarget = new targets.SfnStateMachine(targetStateMachine,
 );
 
 const pipe = new pipes.Pipe(this, 'Pipe', {
-    source: new SomeSource(sourceQueue),
+    source: new SqsSource(sourceQueue),
     target: pipeTarget
 });
 ```
@@ -121,7 +121,7 @@ const pipeTarget = new targets.SfnStateMachine(targetStateMachine,
 );
 
 const pipe = new pipes.Pipe(this, 'Pipe', {
-    source: new SomeSource(sourceQueue),
+    source: new SqsSource(sourceQueue),
     target: pipeTarget
 });
 ```
@@ -137,7 +137,7 @@ declare const targetFunction: lambda.IFunction;
 const pipeTarget = new targets.LambdaFunction(targetFunction,{});
 
 const pipe = new pipes.Pipe(this, 'Pipe', {
-    source: new SomeSource(sourceQueue),
+    source: new SqsSource(sourceQueue),
     target: pipeTarget
 });
 ```
@@ -153,7 +153,7 @@ const pipeTarget = new targets.LambdaFunction(targetFunction, {
 });
 
 const pipe = new pipes.Pipe(this, 'Pipe', {
-    source: new SomeSource(sourceQueue),
+    source: new SqsSource(sourceQueue),
     target: pipeTarget
 });
 ```
@@ -169,7 +169,7 @@ const pipeTarget = new targets.LambdaFunction(targetFunction, {
 });
 
 const pipe = new pipes.Pipe(this, 'Pipe', {
-    source: new SomeSource(sourceQueue),
+    source: new SqsSource(sourceQueue),
     target: pipeTarget
 });
 ```

diff --git a/packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.api-destination.ts b/packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.api-destination.ts
@@ -1,5 +1,4 @@
 import { Pipe } from '@aws-cdk/aws-pipes-alpha';
-// eslint-disable-next-line import/no-extraneous-dependencies
 import { SqsSource } from '@aws-cdk/aws-pipes-sources-alpha';
 import { ExpectedResult, IntegTest } from '@aws-cdk/integ-tests-alpha';
 import * as cdk from 'aws-cdk-lib';

diff --git a/packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.ts b/packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.ts
@@ -1,5 +1,4 @@
 import { Pipe } from '@aws-cdk/aws-pipes-alpha';
-// eslint-disable-next-line import/no-extraneous-dependencies
 import { SqsSource } from '@aws-cdk/aws-pipes-sources-alpha';
 import { IntegTest } from '@aws-cdk/integ-tests-alpha';
 import * as cdk from 'aws-cdk-lib';