From 64e29a3d5d7f28483be2f2826db29ca6a29dc338 Mon Sep 17 00:00:00 2001 From: Andreas Valder <andreasv@fsmpi.rwth-aachen.de> Date: Wed, 12 Apr 2017 05:02:39 +0200 Subject: [PATCH] even faster thumbnails --- manager.py | 4 +++- worker.py | 2 +- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/manager.py b/manager.py index ac1ceae..5f4a6a9 100755 --- a/manager.py +++ b/manager.py @@ -43,6 +43,7 @@ def ping_website_for_host(): if not api.worker_ping(): print("Error sending host ping") +@sched_func(5) def get_job(): if psutil.cpu_percent(interval=3) > 85: return @@ -51,6 +52,7 @@ def get_job(): return print("id: %i, data: %s, all: %s"%(j['id'],j['data'],j)) subprocess.Popen(['./worker.py', str(j['id']), str(j['type']), str(j['priority']) , str(j['data']) ] ) + print("forked") while True: - get_job() + time.sleep(10) diff --git a/worker.py b/worker.py index 5d5e0e9..6ab8dba 100755 --- a/worker.py +++ b/worker.py @@ -26,7 +26,7 @@ if (jobtype == 'thumbnail'): api.job_ping(id=id) duration = float(subprocess.run(["ffprobe", "-v", "error", "-show_entries", "format=duration", "-of", "default=noprint_wrappers=1:nokey=1", inputfile], stdout=subprocess.PIPE).stdout) api.job_ping(id=id) - if subprocess.run(["ffmpeg", "-loglevel", "error", "-ss", str(duration*0.4), "-i", inputfile, "-vf", "scale=640:360", "-frames:v", "1", outputfile]).returncode == 0: + if subprocess.run(["ffmpeg", "-loglevel", "error", "-y", "-ss", str(duration*0.4), "-i", inputfile, "-vf", "scale=640:-1", "-frames:v", "1", outputfile]).returncode == 0: api.job_ping(id=id,state='finished') else: api.job_ping(id=id,state='failed') -- GitLab