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

set enable_delay variable so we can give some time for the incoming stream to be ready

Browse source
This commit is contained in:
deflax 2024-01-13 03:59:50 +02:00
parent df3cbb2781
commit 0f3486a74e
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/scheduler/app.py
View file

@ -25,6 +25,7 @@ api_hostname = os.environ.get('CORE_API_HOSTNAME', 'stream.example.com')
api_username = os.environ.get('CORE_API_AUTH_USERNAME', 'admin') api_username = os.environ.get('CORE_API_AUTH_USERNAME', 'admin')
api_password = os.environ.get('CORE_API_AUTH_PASSWORD', 'pass') api_password = os.environ.get('CORE_API_AUTH_PASSWORD', 'pass')
rec_path = "/recordings" rec_path = "/recordings"
enable_delay = 12
# Init # Init
database = {} database = {}
@ -134,6 +135,8 @@ def update_playhead(stream_id, stream_prio, stream_hls_url):
def exec_stream(stream_id, stream_name, stream_prio, stream_hls_url): def exec_stream(stream_id, stream_name, stream_prio, stream_hls_url):
global prio global prio
logger_job.warning(f'Hello {stream_name}!') logger_job.warning(f'Hello {stream_name}!')
logger_job.warning(f'Waiting {enable_delay} seconds before we initiate the playhead update...')
time.sleep(enable_delay)
if stream_prio > prio: if stream_prio > prio:
prio = stream_prio prio = stream_prio
logger_job.warning(f'Source priority is now set to: {prio}') logger_job.warning(f'Source priority is now set to: {prio}')
@ -158,8 +161,8 @@ def exec_recorder(stream_id, stream_hls_url):
req_counter += 1 req_counter += 1
if requests.get(stream_hls_url).status_code == 200: if requests.get(stream_hls_url).status_code == 200:
logger_job.warning(f'{stream_hls_url} accessible after {req_counter} attempts.') logger_job.warning(f'{stream_hls_url} accessible after {req_counter} attempts.')
# TODO: Wait at least 12 seconds so we wont have broken video. This could be done better... logger_job.warning(f'Waiting {enable_delay} seconds before we initiate the recording...')
time.sleep(12) time.sleep(enable_delay)
break break
if req_counter == 30: if req_counter == 30:
logger_job.error(f'Recording cancelled after {req_counter} attempts.') logger_job.error(f'Recording cancelled after {req_counter} attempts.')