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

Compare commits

base: deflax:af5a7a4b17c987972c3e2b521e00b3627feeb142
Branches Tags
deflax:main
..
compare: deflax:eec8482df310fb64c126f96d2b70a6810ea57d42
Branches Tags
deflax:main

No commits in common. "af5a7a4b17c987972c3e2b521e00b3627feeb142" and "eec8482df310fb64c126f96d2b70a6810ea57d42" have entirely different histories.
af5a7a4b17 ... eec8482df3

1 changed files with 48 additions and 55 deletions
Show stats Expand all files Collapse all files

9
src/scheduler/scheduler.py
View file

@ -179,7 +179,6 @@ def exec_recorder(stream_id, stream_name, stream_hls_url):
video_output = f'{rec_path}/live/{video_file}' video_output = f'{rec_path}/live/{video_file}'
thumb_output = f'{rec_path}/live/{thumb_file}' thumb_output = f'{rec_path}/live/{thumb_file}'
try:
# Record a mp4 file # Record a mp4 file
ffmpeg = ( ffmpeg = (
FFmpeg() FFmpeg()
@ -192,13 +191,8 @@ def exec_recorder(stream_id, stream_name, stream_hls_url):
def on_progress(progress: Progress): def on_progress(progress: Progress):
print(progress) print(progress)
ffmpeg.execute() ffmpeg.execute()
logger_job.warning(f'Recording of {video_file} finished.') logger_job.warning(f'Recording {video_file} finished.')
except Exception as joberror:
logger_job.error(f'Recording of {video_file} failed!')
logger_job.error(joberror)
else:
# Show Metadata # Show Metadata
ffmpeg_metadata = ( ffmpeg_metadata = (
FFmpeg(executable="ffprobe") FFmpeg(executable="ffprobe")
@ -232,7 +226,6 @@ def exec_recorder(stream_id, stream_name, stream_hls_url):
os.rename(f'{video_output}', f'{rec_path}/vod/{video_file}') os.rename(f'{video_output}', f'{rec_path}/vod/{video_file}')
os.rename(f'{thumb_output}', f'{rec_path}/thumb/{thumb_file}') os.rename(f'{thumb_output}', f'{rec_path}/thumb/{thumb_file}')
finally:
# Reset the rechead # Reset the rechead
time.sleep(5) time.sleep(5)
rechead = {} rechead = {}