diff --git a/job_controller/jobs/rescale_video/job.py b/job_controller/jobs/rescale_video/job.py index ab0846f99026b72c0fb5576b7e30a12ab5ef3990..893be4b1451ed2d76e1bc5266513765440552e44 100644 --- a/job_controller/jobs/rescale_video/job.py +++ b/job_controller/jobs/rescale_video/job.py @@ -2,6 +2,7 @@ import logging import shutil import subprocess from pathlib import Path +from time import sleep from videoag_common.ffmpeg import get_file_extension, FFProbe, FFProbeVideoStream from videoag_common.miscellaneous import CJsonObject, MAX_VALUE_SINT32, MIN_VALUE_SINT32 @@ -60,6 +61,9 @@ def execute(database, own_job_id, input_data: CJsonObject): cmd.append(tmp_output_file) res = subprocess.run(cmd) + print(f"FFmpeg finished with exit code: {res.returncode}") + # DEBUG + sleep(60 * 10) if res.returncode != 0: raise Exception(f"ffmpeg returned non-zero exitcode {res.returncode}") @@ -69,3 +73,6 @@ def execute(database, own_job_id, input_data: CJsonObject): output_file.parent.mkdir(parents=True, exist_ok=True) output_file.unlink(missing_ok=True) shutil.move(tmp_output_file, output_file) + + # DEBUG + sleep(60 * 10) diff --git a/job_controller/jobs/rescale_video/metadata.json b/job_controller/jobs/rescale_video/metadata.json index 799f86027ba71c9058d7f969c15f23a467927617..44f983776222c6e17f202745c4b186d97dbb9445 100644 --- a/job_controller/jobs/rescale_video/metadata.json +++ b/job_controller/jobs/rescale_video/metadata.json @@ -2,7 +2,7 @@ "on_workload_node": false, "_TODO_289735": "Make on_workload_node true when that node is setup", "_NOTE ffmpeg randomly fails with too little memory. It has failed sometimes with 4GB, so we have 8GB": "", - "cpu_limit": "2", + "cpu_limit": "1", "memory_limit": "8Gi", "event_listener": [], "data_dir_mount": "/mnt/data"