feat: add automatic downscaling when encountering OOM error

CHANGELOG.md

@@ -7,6 +7,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Fixed
+
+- Added automatic downscaling of the `rows_per_bucket` parameter for ways grouping operation [#50](https://github.com/kraina-ai/quackosm/issues/50)
+
 ## [0.4.4] - 2024-02-14
 
 ### Fixed

pyproject.toml

@@ -117,6 +117,9 @@ preview = true
 [tool.ruff]
 line-length = 100
 target-version = "py39"
+extend-exclude = ["old"]
+
+[tool.ruff.lint]
 select = [
     "E",
     "W",   # pycodestyle
@@ -138,12 +141,11 @@ select = [
     # "ANN",          # flake8-annotations
 ]
 ignore = ["D212"]
-extend-exclude = ["old"]
 
-[tool.ruff.pydocstyle]
+[tool.ruff.lint.pydocstyle]
 convention = "google"
 
-[tool.ruff.pycodestyle]
+[tool.ruff.lint.pycodestyle]
 max-doc-length = 100
 
 [tool.mypy]

quackosm/_osm_tags_filters.py

@@ -29,7 +29,7 @@
 def merge_osm_tags_filter(
     osm_tags_filter: Union[
         OsmTagsFilter, GroupedOsmTagsFilter, Iterable[OsmTagsFilter], Iterable[GroupedOsmTagsFilter]
-    ]
+    ],
 ) -> OsmTagsFilter:
     """
     Merge OSM tags filter into `OsmTagsFilter` type.
@@ -52,12 +52,14 @@
     elif is_expected_type(osm_tags_filter, GroupedOsmTagsFilter):
         return _merge_grouped_osm_tags_filter(cast(GroupedOsmTagsFilter, osm_tags_filter))
     elif is_expected_type(osm_tags_filter, Iterable):
-        return _merge_multiple_osm_tags_filters([
-            merge_osm_tags_filter(
-                cast(Union[OsmTagsFilter, GroupedOsmTagsFilter], sub_osm_tags_filter)
-            )
-            for sub_osm_tags_filter in osm_tags_filter
-        ])
+        return _merge_multiple_osm_tags_filters(
+            [
+                merge_osm_tags_filter(
+                    cast(Union[OsmTagsFilter, GroupedOsmTagsFilter], sub_osm_tags_filter)
+                )
+                for sub_osm_tags_filter in osm_tags_filter
+            ]
+        )
 
     raise AttributeError(
         "Provided tags don't match required type definitions"

quackosm/_rich_progress.py

@@ -8,6 +8,15 @@
 TOTAL_STEPS = 33
 
 
+def log_message(message: str) -> None:
+    try:  # pragma: no cover
+        from rich import print as rprint
+
+        rprint(message)
+    except ImportError:
+        print(message)
+
+
 class TaskProgressSpinner:
     def __init__(self, step_name: str, step_number: str):
         self.step_name = step_name