Mercurial > hg > auditok
changeset 420:f874558779b9
Refactor workers
| author | Amine Sehili <amine.sehili@gmail.com> |
|---|---|
| date | Fri, 18 Oct 2024 23:32:41 +0200 |
| parents | c2ac3fc1bfbc |
| children | 5e2fe07cd12f |
| files | auditok/cmdline_util.py auditok/workers.py |
| diffstat | 2 files changed, 5 insertions(+), 6 deletions(-) [+] |
line wrap: on
line diff
--- a/auditok/cmdline_util.py Fri Oct 18 23:16:08 2024 +0200 +++ b/auditok/cmdline_util.py Fri Oct 18 23:32:41 2024 +0200 @@ -99,7 +99,6 @@ observers.append(stream_saver) else: - print("Using full stream saver...") reader = workers.StreamSaverWorker( reader, filename=kwargs["save_stream"],
--- a/auditok/workers.py Fri Oct 18 23:16:08 2024 +0200 +++ b/auditok/workers.py Fri Oct 18 23:32:41 2024 +0200 @@ -91,7 +91,7 @@ self._detections = [] self._log_format = "[DET]: Detection {0.id} (start: {0.start:.3f}, " self._log_format += "end: {0.end:.3f}, duration: {0.duration:.3f})" - Worker.__init__(self, timeout=0.2, logger=logger) + super().__init__(timeout=0.2, logger=logger) def _process_message(self): pass @@ -434,7 +434,7 @@ self._player = player self._progress_bar = progress_bar self._log_format = "[PLAY]: Detection {id} played" - Worker.__init__(self, timeout=timeout, logger=logger) + super().__init__(timeout=timeout, logger=logger) def _process_message(self, message): _id, audio_region = message @@ -459,7 +459,7 @@ self._audio_format = audio_format self._audio_parameters = audio_parameters self._debug_format = "[SAVE]: Detection {id} saved as '{filename}'" - Worker.__init__(self, timeout=timeout, logger=logger) + super().__init__(timeout=timeout, logger=logger) def _process_message(self, message): _id, audio_region = message @@ -480,7 +480,7 @@ class CommandLineWorker(Worker): def __init__(self, command, timeout=0.2, logger=None): self._command = command - Worker.__init__(self, timeout=timeout, logger=logger) + super().__init__(timeout=timeout, logger=logger) self._debug_format = "[COMMAND]: Detection {id} command: '{command}'" def _process_message(self, message): @@ -507,7 +507,7 @@ self._format_time = make_duration_formatter(time_format) self._timestamp_format = timestamp_format self.detections = [] - Worker.__init__(self, timeout=timeout) + super().__init__(timeout=timeout) def _process_message(self, message): _id, audio_region = message