check if stream_hls_url exists before we exec the recording

src/scheduler/app.py

@@ -1,7 +1,8 @@
 import os
+import time
 import logging
 import json
-import time
+import requests
 from datetime import datetime
 from flask import Flask, render_template, jsonify, request
 from apscheduler.schedulers.background import BackgroundScheduler
@@ -154,17 +155,23 @@ def exec_recorder(stream_id, stream_hls_url):
     output_file = current_datetime + ".mp4"
     if rechead != "":
         logger_job.error('Recorder is already started. Refusing to start another rec job.')
-        return False
     else:
+        # Check if the stream_hls_url returns 200
+        req_counter = 0
+        while True:
+            req_counter += 1
+            if requests.get(stream_hls_url).status_code == 200:
+                logger_job.warning(f'{stream_hls_url} accessible after {req_counter} attempts.')
+                break    
         logger_job.warning(f'Starting recording job for {output_file}')
         rechead = stream_id
-    ffmpeg = (
-        FFmpeg()
-        .option("y")
-        .input(stream_hls_url)
-        .output(output_file, vcodec="copy")
-    )
-    ffmpeg.execute()
+        ffmpeg = (
+            FFmpeg()
+            .option("y")
+            .input(stream_hls_url)
+            .output(output_file, vcodec="copy")
+        )
+        ffmpeg.execute()
 
 def core_api_sync():
     global database

src/scheduler/requirements.txt

@@ -7,4 +7,5 @@ MarkupSafe==2.1.3
 waitress==2.1.2
 Werkzeug==3.0.1
 APScheduler==3.10.4
-python-ffmpeg==2.0.10
+python-ffmpeg==2.0.10
+requests==2.31.0