commit changes to replication log table

Fixes #2350.
This commit is contained in:
Sarah Hoffmann 2021-05-26 11:47:08 +02:00
parent f74dc38766
commit cc2f152d70

View File

@ -116,6 +116,7 @@ class UpdateReplication:
if state is not replication.UpdateState.NO_CHANGES:
status.log_status(conn, start, 'import')
batchdate, _, _ = status.get_status(conn)
conn.commit()
if state is not replication.UpdateState.NO_CHANGES and args.do_index:
index_start = dt.datetime.now(dt.timezone.utc)
@ -127,6 +128,7 @@ class UpdateReplication:
with connect(args.config.get_libpq_dsn()) as conn:
status.set_indexed(conn, True)
status.log_status(conn, index_start, 'index')
conn.commit()
else:
index_start = None