diff --git a/job_controller/jobs/ffmpeg_filter_graph_target/job.py b/job_controller/jobs/ffmpeg_filter_graph_target/job.py index 30f05439b08267a57b4ec9409b623f0383320358..e87295f8ab753652a6ca0149d80a3096a907ad02 100644 --- a/job_controller/jobs/ffmpeg_filter_graph_target/job.py +++ b/job_controller/jobs/ffmpeg_filter_graph_target/job.py @@ -247,10 +247,14 @@ def execute(database, own_job_id, input_data: CJsonObject): cmd = context.build_cmd() - print(f"UNSAFE: {' '.join(str(a) for a in cmd)}") - print(cmd, flush=True) + logger.info(f"UNSAFE: {' '.join(str(a) for a in cmd)}") + logger.info(cmd) process_res = subprocess.run(cmd) if process_res.returncode != 0: raise ValueError(f"FFmpeg returned non-zero exit code: {process_res.returncode}") + logger.info("FFmpeg finished. Moving file to final destination...") + context.move_output_files_to_final_destination() + + logger.info("Finished")