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

show head position and fix the exception handler type

Browse source
This commit is contained in:
deflax 2024-01-07 01:47:51 +02:00
parent a6469fe208
commit 3ca3302bff
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/app.py
View file

@ -48,9 +48,9 @@ def tick():
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)) logger_job.info('Hello {}, your priority is: {}'. format(stream_name, stream_prio))
logger_job.info('HLS: ' + stream_hls_url)
head = { "head": stream_hls_url } head = { "head": stream_hls_url }
logger_job.info('head position is: ' + str(head))
def core_api_sync(): def core_api_sync():
global database global database
@ -101,7 +101,7 @@ def core_api_sync():
stream_start_hour = epg_result['start_at'] stream_start_hour = epg_result['start_at']
logger_job.info("Stream start hour is set to " + stream_start_hour) logger_job.info("Stream start hour is set to " + stream_start_hour)
scheduler.add_job(func=stream_exec, trigger='cron', hour=stream_start_hour, jitter=60, id=stream_id, args=(stream_name, stream_prio, stream_hls_url)) scheduler.add_job(func=stream_exec, trigger='cron', hour=stream_start_hour, jitter=60, id=stream_id, args=(stream_name, stream_prio, stream_hls_url))
except KeyError: except TypeError:
logger_job.info("Stream should start now") logger_job.info("Stream should start now")
scheduler.add_job(func=stream_exec, id=stream_id, args=(stream_name, stream_prio, stream_hls_url)) scheduler.add_job(func=stream_exec, id=stream_id, args=(stream_name, stream_prio, stream_hls_url))
database.update(payload) database.update(payload)
@ -157,6 +157,7 @@ scheduler.start()
fallback = { "head": "https://stream.deflax.net/memfs/938a36f8-02ff-4452-a7e5-3b6a9a07cdfa.m3u8" } fallback = { "head": "https://stream.deflax.net/memfs/938a36f8-02ff-4452-a7e5-3b6a9a07cdfa.m3u8" }
head = fallback head = fallback
logger_api.info('head position is: ' + str(head))
@app.route('/', methods=['GET']) @app.route('/', methods=['GET'])
def root_query(): def root_query():