diff --git a/src/dailyai/transports/abstract_transport.py b/src/dailyai/transports/abstract_transport.py
new file mode 100644
index 000000000..6b9c9549c
--- /dev/null
+++ b/src/dailyai/transports/abstract_transport.py
@@ -0,0 +1,12 @@
+from abc import abstractmethod
+
+from dailyai.pipeline.pipeline import Pipeline
+
+
+class AbstractTransport:
+    def __init__(self, **kwargs):
+        pass
+
+    @abstractmethod
+    async def run(self, pipeline: Pipeline, override_pipeline_source_queue=True):
+        pass
diff --git a/src/dailyai/transports/base_transport.py b/src/dailyai/transports/threaded_transport.py
similarity index 99%
rename from src/dailyai/transports/base_transport.py
rename to src/dailyai/transports/threaded_transport.py
index 43803edc5..50bd56cda 100644
--- a/src/dailyai/transports/base_transport.py
+++ b/src/dailyai/transports/threaded_transport.py
@@ -193,8 +193,7 @@ class ThreadedTransport:
     async def run_interruptible_pipeline(
         self,
         pipeline: Pipeline,
-        allow_interruptions=True,
-        pre_processor=None,
+        pre_processor: FrameProcessor | None = None,
         post_processor: FrameProcessor | None = None,
     ):
         pipeline.set_sink(self.send_queue)