diff --git a/CHANGELOG.md b/CHANGELOG.md
index 1413fab4b..a65ee1a7b 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -7,6 +7,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Added
+
+- Added `test/utils.py` inside of pipecat package.
+
 ### Fixed
 
 - Fixed an issue where `ElevenLabsTTSService` messages would return a 1009 websocket error by increasing the max message size limit to 16MB.
diff --git a/src/pipecat/tests/__init__.py b/src/pipecat/tests/__init__.py
new file mode 100644
index 000000000..e69de29bb
diff --git a/tests/utils.py b/src/pipecat/tests/utils.py
similarity index 100%
rename from tests/utils.py
rename to src/pipecat/tests/utils.py
diff --git a/tests/test_aggregators.py b/tests/test_aggregators.py
index cc03fda52..5eb6cc40f 100644
--- a/tests/test_aggregators.py
+++ b/tests/test_aggregators.py
@@ -16,7 +16,7 @@ from pipecat.frames.frames import (
 )
 from pipecat.processors.aggregators.gated import GatedAggregator
 from pipecat.processors.aggregators.sentence import SentenceAggregator
-from tests.utils import run_test
+from pipecat.tests.utils import run_test
 
 
 class TestSentenceAggregator(unittest.IsolatedAsyncioTestCase):
diff --git a/tests/test_filters.py b/tests/test_filters.py
index e831f4071..4a0fa6a25 100644
--- a/tests/test_filters.py
+++ b/tests/test_filters.py
@@ -19,7 +19,7 @@ from pipecat.processors.filters.frame_filter import FrameFilter
 from pipecat.processors.filters.function_filter import FunctionFilter
 from pipecat.processors.filters.identity_filter import IdentityFilter
 from pipecat.processors.filters.wake_check_filter import WakeCheckFilter
-from tests.utils import EndTestFrame, run_test
+from pipecat.tests.utils import EndTestFrame, run_test
 
 
 class TestIdentifyFilter(unittest.IsolatedAsyncioTestCase):
diff --git a/tests/test_pipeline.py b/tests/test_pipeline.py
index fefdfa4b6..2264b20c2 100644
--- a/tests/test_pipeline.py
+++ b/tests/test_pipeline.py
@@ -13,7 +13,7 @@ from pipecat.pipeline.pipeline import Pipeline
 from pipecat.pipeline.task import PipelineParams, PipelineTask
 from pipecat.processors.filters.identity_filter import IdentityFilter
 from pipecat.processors.frame_processor import FrameProcessor
-from tests.utils import HeartbeatsObserver, run_test
+from pipecat.tests.utils import HeartbeatsObserver, run_test
 
 
 class TestPipeline(unittest.IsolatedAsyncioTestCase):