services: fix DailyTransport stop/cleanup ordering
This commit is contained in:
@@ -5,6 +5,12 @@ All notable changes to **pipecat** will be documented in this file.
|
|||||||
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
|
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
|
||||||
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
|
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
|
||||||
|
|
||||||
|
## [Unreleased]
|
||||||
|
|
||||||
|
### Fixed
|
||||||
|
|
||||||
|
- Fixed `DailyInputTransport` and `DailyOutputTransport` stop/cleanup ordering.
|
||||||
|
|
||||||
## [0.0.13] - 2024-05-14
|
## [0.0.13] - 2024-05-14
|
||||||
|
|
||||||
### Changed
|
### Changed
|
||||||
|
|||||||
@@ -421,13 +421,13 @@ class DailyInputTransport(BaseInputTransport):
|
|||||||
await self._session.join()
|
await self._session.join()
|
||||||
|
|
||||||
async def stop(self):
|
async def stop(self):
|
||||||
await super().stop()
|
|
||||||
await self._session.leave()
|
await self._session.leave()
|
||||||
|
await super().stop()
|
||||||
|
|
||||||
async def cleanup(self):
|
async def cleanup(self):
|
||||||
await super().cleanup()
|
|
||||||
self._camera_in_thread.join()
|
self._camera_in_thread.join()
|
||||||
await self._session.cleanup()
|
await self._session.cleanup()
|
||||||
|
await super().cleanup()
|
||||||
|
|
||||||
def vad_analyze(self, audio_frames: bytes) -> VADState:
|
def vad_analyze(self, audio_frames: bytes) -> VADState:
|
||||||
return self._session.vad_analyze(audio_frames)
|
return self._session.vad_analyze(audio_frames)
|
||||||
@@ -522,12 +522,12 @@ class DailyOutputTransport(BaseOutputTransport):
|
|||||||
await self._session.join()
|
await self._session.join()
|
||||||
|
|
||||||
async def stop(self):
|
async def stop(self):
|
||||||
await super().stop()
|
|
||||||
await self._session.leave()
|
await self._session.leave()
|
||||||
|
await super().stop()
|
||||||
|
|
||||||
async def cleanup(self):
|
async def cleanup(self):
|
||||||
await super().cleanup()
|
|
||||||
await self._session.cleanup()
|
await self._session.cleanup()
|
||||||
|
await super().cleanup()
|
||||||
|
|
||||||
def write_raw_audio_frames(self, frames: bytes):
|
def write_raw_audio_frames(self, frames: bytes):
|
||||||
self._session.write_raw_audio_frames(frames)
|
self._session.write_raw_audio_frames(frames)
|
||||||
|
|||||||
Reference in New Issue
Block a user