Submitting jobs

qiita_pet/handlers/api_proxy/prep_template.py

@@ -438,6 +438,7 @@ def prep_template_patch_req(user_id, req_op, req_path, req_value=None,
 
             r_client.set(PREP_TEMPLATE_KEY_FORMAT % prep_id,
                          dumps({'job_id': job.id}))
+            job.submit()
         else:
             # We don't understand the attribute so return an error
             return {'status': 'error',
@@ -473,6 +474,7 @@ def prep_template_patch_req(user_id, req_op, req_path, req_value=None,
         # Store the job id attaching it to the sample template id
         r_client.set(PREP_TEMPLATE_KEY_FORMAT % prep_id,
                      dumps({'job_id': job.id}))
+        job.submit()
         return {'status': 'success', 'message': '', 'row_id': row_id}
     else:
         return {'status': 'error',

qiita_pet/handlers/api_proxy/sample_template.py

@@ -399,6 +399,8 @@ def sample_template_put_req(study_id, user_id, sample_template):
     r_client.set(SAMPLE_TEMPLATE_KEY_FORMAT % study_id,
                  dumps({'job_id': job.id}))
 
+    job.submit()
+
     return {'status': status,
             'message': msg,
             'file': sample_template}
@@ -441,6 +443,8 @@ def sample_template_delete_req(study_id, user_id):
     r_client.set(SAMPLE_TEMPLATE_KEY_FORMAT % study_id,
                  dumps({'job_id': job.id}))
 
+    job.submit()
+
     return {'status': 'success', 'message': ''}
 
 
@@ -543,6 +547,8 @@ def sample_template_patch_request(user_id, req_op, req_path, req_value=None,
         r_client.set(SAMPLE_TEMPLATE_KEY_FORMAT % st_id,
                      dumps({'job_id': job.id}))
 
+        job.submit()
+
         return {'status': 'success', 'message': '', 'row_id': row_id}
 
     else: