diff --git a/swh/scheduler/celery_backend/listener.py b/swh/scheduler/celery_backend/listener.py
--- a/swh/scheduler/celery_backend/listener.py
+++ b/swh/scheduler/celery_backend/listener.py
@@ -86,6 +86,7 @@
             function(*args, **kwargs)
 
         db.conn.commit()
+        backend.put_db(db)
         for message in messages:
             if not message.acknowledged:
                 message.ack()