sets own job ID on RQ jobs in production

2017-11-02 08:32:55 +01:00
parent df7577813f
commit b17cf3d6dd
4 changed files with 27 additions and 6 deletions
--- a/rowers/tasks.py
+++ b/rowers/tasks.py
@@ -53,10 +53,17 @@ def long_test_task(self,aantal,debug=False,job=None,session_key=None):
                             session_key=session_key)
    
@app.task(bind=True)
-def long_test_task2(self,aantal,debug=False,job=None):
+def long_test_task2(self,aantal,**kwargs):
+                    #debug=False,job=None,jobid='aap'):
    job = self.request
-
-    return longtask.longtask2(aantal,jobid=job.id,debug=debug)
+    job_id = job.id
+    
+    if 'jobkey' in kwargs:
+        job_id = kwargs.pop('jobkey')
+        
+    kwargs['jobid'] = job_id
+        
+    return longtask.longtask2(aantal,**kwargs)
    
 # create workout
@app.task