deflax/television
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

execute data sync faster

Browse source
This commit is contained in:
deflax 2024-01-18 00:45:14 +02:00
parent 43db5723be
commit 9196707c9c
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/scheduler/scheduler.py
View file

@ -90,7 +90,7 @@ def process_running_channel(database, scheduler, stream_id, stream_name, stream_
# Bootstrap the playhead if its still empty. # Bootstrap the playhead if its still empty.
if playhead == {}: if playhead == {}:
fallback = fallback_search(database) fallback = fallback_search(database)
scheduler.add_job(func=exec_stream, id="fallback", args=(fallback['stream_id'], fallback['stream_name'], 0, fallback['stream_hls_url'])) scheduler.add_job(func=exec_stream, id='fallback', args=(fallback['stream_id'], fallback['stream_name'], 0, fallback['stream_hls_url']))
# Remove channel from the database # Remove channel from the database
def remove_channel_from_database(database, scheduler, stream_id, stream_name, state): def remove_channel_from_database(database, scheduler, stream_id, stream_name, state):
@ -110,7 +110,7 @@ def remove_channel_from_database(database, scheduler, stream_id, stream_name, st
fallback = fallback_search(database) fallback = fallback_search(database)
prio = 0 prio = 0
logger_job.warning(f'Source priority is reset to 0') logger_job.warning(f'Source priority is reset to 0')
scheduler.add_job(func=exec_stream, id="fallback", args=(fallback['stream_id'], fallback['stream_name'], prio, fallback['stream_hls_url'])) scheduler.add_job(func=exec_stream, id='fallback', args=(fallback['stream_id'], fallback['stream_name'], prio, fallback['stream_hls_url']))
# Search for a fallback stream # Search for a fallback stream
def fallback_search(database): def fallback_search(database):
@ -262,7 +262,8 @@ except Exception as err:
#sys.exit(1) #sys.exit(1)
# Schedule sync jobs # Schedule sync jobs
scheduler.add_job(func=core_api_sync, trigger="interval", seconds=CORE_SYNC_PERIOD, id="core_api_sync") scheduler.add_job(func=core_api_sync, trigger='interval', seconds=CORE_SYNC_PERIOD, id='core_api_sync')
scheduler.get_job('core_api_sync').modify(next_run_time=datetime.now())
# Start the scheduler # Start the scheduler
scheduler.start() scheduler.start()