Handle keyerror in stream trimmer
This commit is contained in:
parent
7193665086
commit
f05d192a1b
@ -406,8 +406,12 @@ def stream_trimmer_loop():
|
|||||||
if CONFIG['SYSTEMS'][system]['MODE'] == 'OPENBRIDGE':
|
if CONFIG['SYSTEMS'][system]['MODE'] == 'OPENBRIDGE':
|
||||||
remove_list = []
|
remove_list = []
|
||||||
for stream_id in systems[system].STATUS:
|
for stream_id in systems[system].STATUS:
|
||||||
|
try:
|
||||||
if systems[system].STATUS[stream_id]['LAST'] < _now - 5:
|
if systems[system].STATUS[stream_id]['LAST'] < _now - 5:
|
||||||
remove_list.append(stream_id)
|
remove_list.append(stream_id)
|
||||||
|
except 'KeyError':
|
||||||
|
logger.debug("Keyerror - stream trimmer")
|
||||||
|
continue
|
||||||
for stream_id in remove_list:
|
for stream_id in remove_list:
|
||||||
if stream_id in systems[system].STATUS:
|
if stream_id in systems[system].STATUS:
|
||||||
_stream = systems[system].STATUS[stream_id]
|
_stream = systems[system].STATUS[stream_id]
|
||||||
|
Loading…
Reference in New Issue
Block a user