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

update the head based on global and stream prio

Browse source
This commit is contained in:
deflax 2024-01-07 04:01:27 +02:00
parent d1841f377a
commit 967b2a4166
1 changed files with 15 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
src/scheduler/app.py
View file

@ -84,12 +84,23 @@ def find_event_entry(events, target_name):
return {"start_at": entry.get("start_at"), "prio": entry.get("prio")} return {"start_at": entry.get("start_at"), "prio": entry.get("prio")}
return None return None
# Helper function to update the head
def update_head(stream_hls_url):
head = { "head": stream_hls_url }
logger_job.info(f'Head position is: {str(head)}')
# Tasks # Tasks
def stream_exec(stream_name, stream_prio, stream_hls_url): def stream_exec(stream_name, stream_prio, stream_hls_url):
global head global head
logger_job.info('Hello {}, your priority is: {}'. format(stream_name, stream_prio)) global prio
head = { "head": stream_hls_url } logger_job.info(f'Hello {stream_name}!')
logger_job.info('head position is: ' + str(head)) if stream_prio > prio:
logger_job.info(f'Source priority is now set to: {stream_prio}')
update_head(stream_hls_url)
elif stream_prio == prio:
update_head(stream_hls_url)
elif stream_prio < prio:
logger_job.warning(f'Source with higher priority ({prio}) is blocking. Skipping head update!')
def core_api_sync(): def core_api_sync():
global database global database