Hotfix release

Author: dolfinus

data_rentgen/openlineage/dataset_facets/input_statistics.py

@@ -1,7 +1,7 @@
 # SPDX-FileCopyrightText: 2024-2025 MTS PJSC
 # SPDX-License-Identifier: Apache-2.0
 
-from pydantic import Field, PositiveInt, field_validator
+from pydantic import Field, NonNegativeInt, field_validator
 
 from data_rentgen.openlineage.dataset_facets.base import (
     OpenLineageInputDatasetFacet,
@@ -15,9 +15,9 @@ class OpenLineageInputStatisticsInputDatasetFacet(OpenLineageInputDatasetFacet):
     See [InputStatisticsInputDatasetFacet](https://github.com/OpenLineage/OpenLineage/blob/main/spec/facets/InputStatisticsInputDatasetFacet.json).
     """
 
-    rows: PositiveInt | None = Field(default=None, alias="rowCount", examples=[1_000_000])
-    bytes: PositiveInt | None = Field(default=None, alias="size", examples=[2**30])
-    files: PositiveInt | None = Field(default=None, alias="fileCount", examples=[0])
+    rows: NonNegativeInt | None = Field(default=None, alias="rowCount", examples=[1_000_000])
+    bytes: NonNegativeInt | None = Field(default=None, alias="size", examples=[2**30])
+    files: NonNegativeInt | None = Field(default=None, alias="fileCount", examples=[0])
 
     @field_validator("bytes", "rows", "files", mode="after")
     @classmethod

data_rentgen/openlineage/dataset_facets/output_statistics.py

@@ -1,7 +1,7 @@
 # SPDX-FileCopyrightText: 2024-2025 MTS PJSC
 # SPDX-License-Identifier: Apache-2.0
 
-from pydantic import Field
+from pydantic import Field, NonNegativeInt
 
 from data_rentgen.openlineage.dataset_facets.base import (
     OpenLineageOutputDatasetFacet,
@@ -13,6 +13,6 @@ class OpenLineageOutputStatisticsOutputDatasetFacet(OpenLineageOutputDatasetFace
     See [OutputStatisticsOutputDatasetFacet](https://github.com/OpenLineage/OpenLineage/blob/main/spec/facets/OutputStatisticsOutputDatasetFacet.json).
     """
 
-    rows: int | None = Field(default=None, alias="rowCount", examples=[1_000_000])
-    bytes: int | None = Field(default=None, alias="size", examples=[2**30])
-    files: int | None = Field(default=None, alias="fileCount", examples=[0])
+    rows: NonNegativeInt | None = Field(default=None, alias="rowCount", examples=[1_000_000])
+    bytes: NonNegativeInt | None = Field(default=None, alias="size", examples=[2**30])
+    files: NonNegativeInt | None = Field(default=None, alias="fileCount", examples=[0])

docs/changelog/0.4.4.rst

@@ -0,0 +1,8 @@
+0.4.4 (2025-11-21)
+==================
+
+Bug Fixes
+---------
+
+- 0.4.3 release broken inputs with 0 bytes statistics, fixed
+

docs/changelog/index.rst

@@ -3,6 +3,7 @@
     :caption: Changelog
 
     DRAFT
+    0.4.4
     0.4.3
     0.4.2
     0.4.1

tests/test_consumer/test_extractors/test_extractors_interaction.py

@@ -116,6 +116,7 @@ def test_extractors_extract_input_output_schema_no_fields(dataset_type: type[Ope
     ["row_count", "byte_count", "file_count"],
     [
         (1_000_000, 1000 * 1024 * 1024, 10),
+        (0, 0, 0),
         (None, None, None),
     ],
 )
@@ -205,6 +206,7 @@ def test_extractors_extract_input_for_long_operations():
     ["row_count", "byte_count", "file_count"],
     [
         (1_000_000, 1000 * 1024 * 1024, 10),
+        (0, 0, 0),
         (None, None, None),
     ],
 )