X-Git-Url: https://git.openstreetmap.org./nominatim.git/blobdiff_plain/bc75e5626ec59523707b842022ecf0bdc159cf06..ae8694a6a6862d7cb66cd91102d2802c9899e7cf:/src/nominatim_db/clicmd/replication.py diff --git a/src/nominatim_db/clicmd/replication.py b/src/nominatim_db/clicmd/replication.py index ba4c7730..da60eafe 100644 --- a/src/nominatim_db/clicmd/replication.py +++ b/src/nominatim_db/clicmd/replication.py @@ -22,10 +22,6 @@ from .args import NominatimArgs LOG = logging.getLogger() -# Do not repeat documentation of subcommand classes. -# pylint: disable=C0111 -# Using non-top-level imports to make pyosmium optional for replication only. -# pylint: disable=C0415 class UpdateReplication: """\ @@ -71,7 +67,6 @@ class UpdateReplication: group.add_argument('--socket-timeout', dest='socket_timeout', type=int, default=60, help='Set timeout for file downloads') - def _init_replication(self, args: NominatimArgs) -> int: from ..tools import replication, refresh @@ -84,7 +79,6 @@ class UpdateReplication: refresh.create_functions(conn, args.config, True, False) return 0 - def _check_for_updates(self, args: NominatimArgs) -> int: from ..tools import replication @@ -92,7 +86,6 @@ class UpdateReplication: return replication.check_for_updates(conn, base_url=args.config.REPLICATION_URL, socket_timeout=args.socket_timeout) - def _report_update(self, batchdate: dt.datetime, start_import: dt.datetime, start_index: Optional[dt.datetime]) -> None: @@ -106,7 +99,6 @@ class UpdateReplication: round_time(end - start_import), round_time(end - batchdate)) - def _compute_update_interval(self, args: NominatimArgs) -> int: if args.catch_up: return 0 @@ -123,9 +115,7 @@ class UpdateReplication: return update_interval - async def _update(self, args: NominatimArgs) -> None: - # pylint: disable=too-many-locals from ..tools import replication from ..indexer.indexer import Indexer from ..tokenizer import factory as tokenizer_factory @@ -186,7 +176,6 @@ class UpdateReplication: LOG.warning("No new changes. Sleeping for %d sec.", recheck_interval) time.sleep(recheck_interval) - def run(self, args: NominatimArgs) -> int: socket.setdefaulttimeout(args.socket_timeout)