Fix non-multichannel sessions

Author: James Walker

CHANGELOG.md

@@ -5,6 +5,11 @@ All notable changes to this project will be documented in this file.
 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).
 
+## [4.0.4] - 2025-06-09
+
+- Fixed non-multichannel sessions bugging out after adding multichannel support
+
+
 ## [4.0.3] - 2025-06-06
 
 - Fixed microphone transcription tests not working after adding multichan dz support

VERSION

@@ -1 +1 @@
-4.0.3
+4.0.4

speechmatics/cli.py

@@ -810,21 +810,19 @@ def rt_main(args):
 
     def run(stream=None, channel_stream_pairs=None):
         try:
-            # Pass in either stream or channel_stream_pairs depending on what != None
-            # Dynamically construct the args based on the input
-            args_list = [transcription_config]
+            stream_or_channel_stream_pairs = None
             if stream is not None:
-                args_list.append(stream)
+                stream_or_channel_stream_pairs = stream
             elif channel_stream_pairs is not None:
-                args_list.append(None)  # This skips the stream argument
-                args_list.append(channel_stream_pairs)
+                stream_or_channel_stream_pairs = channel_stream_pairs
             else:
                 raise SystemExit(
                     "Neither stream nor channel_stream_pairs were provided."
                 )
             api.run_synchronously(
-                *args_list,
-                audio_settings=get_audio_settings(args),
+                stream_or_channel_stream_pairs,
+                transcription_config,
+                get_audio_settings(args),
                 from_cli=True,
                 extra_headers=extra_headers,
             )

speechmatics/client.py

@@ -9,6 +9,7 @@
 from collections import defaultdict
 from contextlib import AsyncExitStack
 import copy
+from io import IOBase
 import json
 import logging
 import os
@@ -521,9 +522,8 @@ async def _communicate(self, stream, audio_settings):
 
     async def run(
         self,
+        stream: Union[IOBase, dict],
         transcription_config: TranscriptionConfig,
-        stream: Optional[Any] = None,
-        channel_stream_pairs=None,
         audio_settings: AudioSettings = None,
         from_cli: bool = False,
         extra_headers: Dict = None,
@@ -552,7 +552,14 @@ async def run(
         :raises Exception: Can raise any exception returned by the
             consumer/producer tasks.
         """
-        if channel_stream_pairs:
+        # Check we get either a dict or a file-like object
+        channel_stream_pairs = None
+        if isinstance(stream, dict):
+            # Case where stream is channel stream pairs
+            channel_stream_pairs = stream
+
+        # Set channel_stream pairs if provided
+        if channel_stream_pairs is not None:
             opened_streams = {}
             self._stream_exits = AsyncExitStack()
             for channel_name, path in channel_stream_pairs.items():
@@ -564,6 +571,7 @@ async def run(
             self.channel_stream_pairs = opened_streams
         else:
             self.channel_stream_pairs = None
+
         self.transcription_config = transcription_config
         self._language_pack_info = None
         await self._init_synchronization_primitives()