conn = connect(args.config.get_libpq_dsn())
start = dt.datetime.now(dt.timezone.utc)
state = replication.update(conn, params)
- status.log_status(conn, start, 'import')
+ if state is not replication.UpdateState.NO_CHANGES:
+ status.log_status(conn, start, 'import')
batchdate, _, _ = status.get_status(conn)
conn.close()
repl = ReplicationServer(options['base_url'])
outhandler = WriteHandler(str(options['import_file']))
- endseq = repl.apply_diffs(outhandler, startseq,
+ endseq = repl.apply_diffs(outhandler, startseq + 1,
max_size=options['max_diff_size'] * 1024)
outhandler.close()