catch exception and replace with a debug message, refs #22
This commit is contained in:
parent
77ae13723d
commit
9b187140ff
@ -183,9 +183,14 @@ class AudioWriter(object):
|
|||||||
stdout=subprocess.PIPE,
|
stdout=subprocess.PIPE,
|
||||||
cwd=self.tmp_dir,
|
cwd=self.tmp_dir,
|
||||||
close_fds=True,
|
close_fds=True,
|
||||||
)
|
)
|
||||||
for line in decoder.stdout:
|
try:
|
||||||
self.outputWriter.send((job.freq, line))
|
for line in decoder.stdout:
|
||||||
|
self.outputWriter.send((job.freq, line))
|
||||||
|
except OSError:
|
||||||
|
decoder.stdout.flush()
|
||||||
|
# TODO uncouple parsing from the output so that decodes can still go to the map and the spotters
|
||||||
|
logger.debug("output has gone away while decoding job.")
|
||||||
try:
|
try:
|
||||||
rc = decoder.wait(timeout=10)
|
rc = decoder.wait(timeout=10)
|
||||||
if rc != 0:
|
if rc != 0:
|
||||||
|
Loading…
x
Reference in New Issue
Block a user