remove unused imports

This commit is contained in:
Jakob Ketterl 2021-05-01 16:51:02 +02:00
parent 2152184bf9
commit 11568256ed
2 changed files with 4 additions and 3 deletions

View File

@ -4,7 +4,7 @@ from itertools import groupby
import threading import threading
from owrx.audio import ProfileSourceSubscriber from owrx.audio import ProfileSourceSubscriber
from owrx.audio.wav import AudioWriter from owrx.audio.wav import AudioWriter
from multiprocessing.connection import Pipe, wait from multiprocessing.connection import Pipe
import logging import logging
@ -33,7 +33,9 @@ class AudioChopper(threading.Thread, Output, ProfileSourceSubscriber):
self.stop_writers() self.stop_writers()
sorted_profiles = sorted(self.profile_source.getProfiles(), key=lambda p: p.getInterval()) sorted_profiles = sorted(self.profile_source.getProfiles(), key=lambda p: p.getInterval())
groups = {interval: list(group) for interval, group in groupby(sorted_profiles, key=lambda p: p.getInterval())} groups = {interval: list(group) for interval, group in groupby(sorted_profiles, key=lambda p: p.getInterval())}
writers = [AudioWriter(self.dsp, self.outputWriter, interval, profiles) for interval, profiles in groups.items()] writers = [
AudioWriter(self.dsp, self.outputWriter, interval, profiles) for interval, profiles in groups.items()
]
for w in writers: for w in writers:
w.start() w.start()
self.writers = writers self.writers = writers

View File

@ -4,7 +4,6 @@ from owrx.audio.queue import QueueJob, DecoderQueue
import threading import threading
import wave import wave
import os import os
from multiprocessing.connection import Pipe
from datetime import datetime, timedelta from datetime import datetime, timedelta
from queue import Full from queue import Full
from typing import List from typing import List