tag job

back/tasks.py

@@ -38,6 +38,7 @@ def l_from_ids(ids,status=None):
         out = job.meta
         out["eq"]=utctolocal(job.enqueued_at).strftime(date_fmt)
         out["working"]=True
+        #out["queue"]=job.queue
         out["result"]=job.result
         if status:
             out["progress"]=status
@@ -99,6 +100,10 @@ def long_job(arg):
 
 @job('default',connection=conn, timeout=360*2, result_ttl=360)
 def crop_video(in_fname,start_time,end_time,out_fname):
+    job = get_current_job()
+    job.meta["type"]="Crop"
+    job.save()
+
     job_start = datetime.datetime.now()
     if not os.path.isfile(in_fname):
         return { "status":"error",
@@ -122,9 +127,6 @@ def crop_video(in_fname,start_time,end_time,out_fname):
                 out_fname
               ]
 
-    job = get_current_job()
-    job.meta["type"]="Crop"
-    job.save()
     out = run_process(process)
     if out == "":
         out = "Proceso finalizado"