diff --git a/e2e/sources/Sqs.ts b/e2e/sources/Sqs.ts
index 7eb5b5a..77e7bcb 100644
--- a/e2e/sources/Sqs.ts
+++ b/e2e/sources/Sqs.ts
@@ -1,4 +1,4 @@
-import { App, RemovalPolicy, Stack } from 'aws-cdk-lib';
+import { App, CfnOutput, RemovalPolicy, Stack } from 'aws-cdk-lib';
 import { LogGroup } from 'aws-cdk-lib/aws-logs';
 import { Queue } from 'aws-cdk-lib/aws-sqs';
 import { LogsTarget, Pipe, SqsSource } from '../../src';
@@ -14,7 +14,12 @@ const targetLogGroup = new LogGroup(stack, 'TargetLogGroup', {
 const target = new LogsTarget(targetLogGroup, {
   logStreamName: 'test',
 });
-new Pipe(stack, 'Pipe', {
+const pipe = new Pipe(stack, 'Pipe', {
   source,
   target,
 });
+// const pipeName = (pipe.node.defaultChild as CfnPipe).ref;
+new CfnOutput(stack, 'PipeName', {
+  value: pipe.pipeName,
+});
+
diff --git a/src/Pipe.ts b/src/Pipe.ts
index ba4fbff..705e3b5 100644
--- a/src/Pipe.ts
+++ b/src/Pipe.ts
@@ -1,7 +1,5 @@
 import {
   IResource,
-  Lazy,
-  Names,
   Resource,
 } from 'aws-cdk-lib';
 import { IRole, Role, ServicePrincipal } from 'aws-cdk-lib/aws-iam';
@@ -110,7 +108,7 @@ export class Pipe extends PipeBase {
 
   constructor(scope: Construct, id: string, props: IPipeProps) {
     const pipeName =
-      props.name || Lazy.string({ produce: () => Names.uniqueId(this) });
+      props.name;
     super(scope, id, { physicalName: pipeName });
 
     this.pipeRole =
@@ -118,7 +116,6 @@ export class Pipe extends PipeBase {
       new Role(this, 'Role', {
         assumedBy: new ServicePrincipal('pipes.amazonaws.com'),
       });
-    this.pipeName = pipeName;
 
     const sourceParameters = {
       ...props.source.sourceParameters,
@@ -143,6 +140,9 @@ export class Pipe extends PipeBase {
       enrichmentParameters: props.enrichment?.enrichmentParameters,
       tags: props.tags,
     });
+
+    this.pipeName = resource.ref;
     this.pipeArn = resource.attrArn;
+
   }
 }