From 0f3486a74e4c46396e009036abcbb4e658a279f0 Mon Sep 17 00:00:00 2001 From: deflax Date: Sat, 13 Jan 2024 03:59:50 +0200 Subject: [PATCH] set enable_delay variable so we can give some time for the incoming stream to be ready --- src/scheduler/app.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/scheduler/app.py b/src/scheduler/app.py index 97079c1..f9d5be7 100644 --- a/src/scheduler/app.py +++ b/src/scheduler/app.py @@ -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_password = os.environ.get('CORE_API_AUTH_PASSWORD', 'pass') rec_path = "/recordings" +enable_delay = 12 # Init 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): global prio 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: prio = stream_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 if requests.get(stream_hls_url).status_code == 200: 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... - time.sleep(12) + logger_job.warning(f'Waiting {enable_delay} seconds before we initiate the recording...') + time.sleep(enable_delay) break if req_counter == 30: logger_job.error(f'Recording cancelled after {req_counter} attempts.')