import logging
import time
-from osmium.replication.server import ReplicationServer
-from osmium import WriteHandler
-
from ..db import status
from .exec_utils import run_osm2pgsql
from ..errors import UsageError
+try:
+ from osmium.replication.server import ReplicationServer
+ from osmium import WriteHandler
+except ModuleNotFoundError as exc:
+ logging.getLogger().fatal("pyosmium not installed. Replication functions not available.\n"
+ "To install pyosmium via pip: pip3 install osmium")
+ raise UsageError("replication tools not available") from exc
+
LOG = logging.getLogger()
def init_replication(conn, base_url):
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()