diff options
| -rw-r--r-- | python/pgq/cascade/worker.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/python/pgq/cascade/worker.py b/python/pgq/cascade/worker.py index a721eaa0..6e7e8067 100644 --- a/python/pgq/cascade/worker.py +++ b/python/pgq/cascade/worker.py @@ -227,6 +227,7 @@ class CascadedWorker(CascadedConsumer): src_curs = src_db.cursor() q = "select * from pgq_node.set_subscriber_watermark(%s, %s, %s)" src_curs.execute(q, [self.pgq_queue_name, st.node_name, wm]) + src_db.commit() # if last part fails, dont repeat it immediately self.local_wm_publish_time = t |