consumer: does a commit to DB on every message

* Properly saves run_finished_at attribute
reanahub · Feb 6, 2020 · acf7fb3 · acf7fb3
1 parent 88ea799
commit acf7fb3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/reana_workflow_controller/consumer.py b/reana_workflow_controller/consumer.py
@@ -71,7 +71,7 @@ def on_message(self, body, message):
                 # Caching: calculate input hash and store in JobCache
                 if 'caching_info' in msg:
                     _update_job_cache(msg)
-                Session.commit()
+            Session.commit()
 
 
 def _update_workflow_status(workflow_uuid, status, logs):