Update changelog for version 0.10.9.1

Author: legout

CHANGELOG.md

@@ -8,6 +8,14 @@
 
 
 
+## [0.10.9.1] - 2025-06-05
+
+### Changes
+- feat: refactor codebase to use attrs for data classes and improve structure
+- refactor: Update import statements for consistency and clarity
+
+
+
 ## [0.10.9.1] - 2025-06-04
 
 ### Changes

src/flowerpower/plugins/io/base.py

@@ -14,8 +14,8 @@
 from ...fs import get_filesystem
 from ...fs.ext import _dict_to_dataframe, path_to_glob
 from ...fs.storage_options import (AwsStorageOptions, AzureStorageOptions,
-                                  GcsStorageOptions, GitHubStorageOptions,
-                                  GitLabStorageOptions, StorageOptions)
+                                   GcsStorageOptions, GitHubStorageOptions,
+                                   GitLabStorageOptions, StorageOptions)
 from ...utils.misc import convert_large_types_to_standard, to_pyarrow_table
 from ...utils.polars import pl
 from ...utils.sql import sql2polars_filter, sql2pyarrow_filter
@@ -1109,6 +1109,7 @@ def metadata(self):
             self._load()
         return self._metadata
 
+
 @attrs.define
 class BaseFileWriter(BaseFileIO):
     """
@@ -1216,6 +1217,7 @@ def metadata(self):
             return {}
         return self._metadata
 
+
 @attrs.define
 class BaseDatasetWriter(BaseFileWriter):
     """
@@ -1400,7 +1402,7 @@ def metadata(self):
         if not hasattr(self, "_metadata"):
             return {}
         return self._metadata
-    
+
 
 @attrs.define
 class BaseDatabaseIO:
@@ -1448,23 +1450,23 @@ class BaseDatabaseIO:
     database: str | None = None
     ssl: bool = False
     _metadata: dict[str, Any] = attrs.field(init=False, factory=dict)
-    _data: pa.Table | pl.DataFrame | pl.LazyFrame | pd.DataFrame | None = attrs.field(init=False, factory=lambda: None)
+    _data: pa.Table | pl.DataFrame | pl.LazyFrame | pd.DataFrame | None = attrs.field(
+        init=False, factory=lambda: None
+    )
 
     def __attrs_post_init__(self):
         db = self.type_.lower()
         if (
             db in ["postgres", "mysql", "mssql", "oracle"]
             and not self.connection_string
         ):
-            if not all(
-                [
-                    self.username,
-                    self.password,
-                    self.server,
-                    self.port,
-                    self.database,
-                ]
-            ):
+            if not all([
+                self.username,
+                self.password,
+                self.server,
+                self.port,
+                self.database,
+            ]):
                 raise ValueError(
                     f"{self.type_} requires connection_string or username, password, server, port, and table_name "
                     "to build it."

src/flowerpower/plugins/io/loader/_duckdb.py

@@ -2,11 +2,11 @@
 import os
 
 import duckdb
+import msgspec
 import pandas as pd
 import polars as pl
 import pyarrow as pa
 import pyarrow.dataset as pds
-import msgspec
 
 
 class DuckDBLoader(msgspec.Struct):

src/flowerpower/plugins/io/loader/csv.py

@@ -1,4 +1,5 @@
 import attrs
+
 from ..base import BaseDatasetReader, BaseFileReader
 
 

src/flowerpower/plugins/io/loader/deltatable.py

@@ -7,9 +7,9 @@
 import pyarrow as pa
 import pyarrow.dataset as pds
 from deltalake import DeltaTable, table
-from deltalake.writer import WriterProperties
-from deltalake.transaction import PostCommitHookProperties, CommitProperties
 from deltalake.exceptions import TableNotFoundError
+from deltalake.transaction import CommitProperties, PostCommitHookProperties
+from deltalake.writer import WriterProperties
 from loguru import logger
 from sherlock import RedisLock
 

src/flowerpower/plugins/io/loader/duckdb.py

@@ -1,4 +1,5 @@
 import attrs
+
 from ..base import BaseDatabaseReader
 
 

src/flowerpower/plugins/io/loader/json.py

@@ -1,4 +1,5 @@
 import attrs
+
 from ..base import BaseFileReader
 
 

src/flowerpower/plugins/io/loader/mqtt.py

@@ -2,12 +2,12 @@
 
 import datafusion
 import duckdb
+import msgspec
 import orjson
 import pandas as pd
 import polars as pl
 import pyarrow as pa
 import pyarrow.dataset as pds
-import msgspec
 
 from ...utils.sql import sql2polars_filter
 from ..metadata import get_dataframe_metadata, get_duckdb_metadata

src/flowerpower/plugins/io/loader/mssql.py

@@ -1,4 +1,5 @@
 import attrs
+
 from ..base import BaseDatabaseReader
 
 

src/flowerpower/plugins/io/loader/mysql.py

@@ -1,4 +1,5 @@
 import attrs
+
 from ..base import BaseDatabaseReader