some more renames

This commit is contained in:
Moishe Lettvin
2024-03-26 15:57:19 -04:00
parent 2fc5de6afe
commit 78c80d8941
2 changed files with 13 additions and 2 deletions

View File

@@ -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

View File

@@ -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)