handle removing missing job ids
This commit is contained in:
parent
e4bd771275
commit
795682484c
1 changed files with 4 additions and 1 deletions
|
@ -72,7 +72,10 @@ def remove_channel_from_database(database, scheduler, stream_id, stream_name, st
|
||||||
if stream_id in database:
|
if stream_id in database:
|
||||||
logger_job.info(f'{stream_id} ({stream_name}) has been removed from the database. Reason: {state.exec}')
|
logger_job.info(f'{stream_id} ({stream_name}) has been removed from the database. Reason: {state.exec}')
|
||||||
database.pop(stream_id)
|
database.pop(stream_id)
|
||||||
scheduler.remove_job(stream_id)
|
try:
|
||||||
|
scheduler.remove_job(stream_id)
|
||||||
|
except scheduler.jobstores.base.JobLookupError as je:
|
||||||
|
logger_job.error(je)
|
||||||
|
|
||||||
# Helper function to find match a stream name with epg.json
|
# Helper function to find match a stream name with epg.json
|
||||||
def find_event_entry(events, target_name):
|
def find_event_entry(events, target_name):
|
||||||
|
|
Loading…
Reference in a new issue