format and lint

Author: zilto

dlt/destinations/impl/ducklake/configuration.py

@@ -33,6 +33,7 @@ class DuckLakeCredentials(DuckDbCredentials):
     of the DuckLake.
 
     """
+
     ducklake_name: str = ":pipeline:"
     catalog: Optional[ConnectionStringCredentials] = None
     storage: Optional[FilesystemConfiguration] = None
@@ -72,7 +73,7 @@ def build_attach_statement(
     def attach_statement(self) -> str:
         # TODO handle when `ducklake_name` or `catalog` is not set
         if not self.is_resolved():
-           return None
+            return None
 
         # return value when set explicitly
         if self._attach_statement:

dlt/destinations/impl/ducklake/sql_client.py

@@ -15,6 +15,7 @@ def __init__(
         capabilities: DestinationCapabilitiesContext,
     ) -> None:
         super().__init__(dataset_name, None, credentials, capabilities)
+        self.credentials = credentials
 
     # TODO support connecting to a snapshot
     @raise_open_connection_error

tests/load/ducklake/test_ducklake_client.py

@@ -85,8 +85,9 @@ def test_default_ducklake_configuration() -> None:
     )
 
     configuration = resolve_configuration(
-        DuckLakeClientConfiguration(pipeline_name=pipeline_name)
-        ._bind_dataset_name(dataset_name="FOO")
+        DuckLakeClientConfiguration(pipeline_name=pipeline_name)._bind_dataset_name(
+            dataset_name="FOO"
+        )
     )
     credentials = configuration.credentials
 
@@ -96,13 +97,13 @@ def test_default_ducklake_configuration() -> None:
     assert credentials.ducklake_name == expected_ducklake_name
 
     assert credentials.database == credentials.catalog.database == str(expected_path)
-    
+
     # currently, we use `drivername="duckdb"` for the ducklake client;
     # if we change it to `drivername="ducklake"`, update this check
     ducklake_client_url = credentials.to_native_representation()
     catalog_url = credentials.catalog.to_native_representation()
     assert ducklake_client_url == catalog_url == expected_db_url
-    
+
     assert credentials.storage is None
     # value is resolved
     assert credentials.attach_statement == expected_attach_statement
@@ -111,10 +112,13 @@ def test_default_ducklake_configuration() -> None:
 def test_ducklake_sqlclient(tmp_path):
     pipeline_name = "foo"
     configuration = resolve_configuration(
-        DuckLakeClientConfiguration(pipeline_name=pipeline_name)
-        ._bind_dataset_name(dataset_name="test_conf")
+        DuckLakeClientConfiguration(pipeline_name=pipeline_name)._bind_dataset_name(
+            dataset_name="test_conf"
+        )
+    )
+    expected_attach_statement = (
+        f"ATTACH IF NOT EXISTS 'ducklake:{pipeline_name}.ducklake' AS {pipeline_name}"
     )
-    expected_attach_statement = f"ATTACH IF NOT EXISTS 'ducklake:{pipeline_name}.ducklake' AS {pipeline_name}"
     assert configuration.credentials.attach_statement == expected_attach_statement
 
     # TODO patch `ducklake` extension directory to unit test extension installation
@@ -146,9 +150,9 @@ def test_ducklake_sqlclient(tmp_path):
 
 
 def test_destination_defaults() -> None:
-    """Check that catalog and storage are materialized at the right 
+    """Check that catalog and storage are materialized at the right
     location and properly derive their name from the pipeline name.
-    
+
     Note that default storage is managed by the ducklake extension itself.
     """
     pipeline = dlt.pipeline("destination_defaults", destination="ducklake")
@@ -175,4 +179,4 @@ def test_destination_defaults() -> None:
 
 
 # def test_assert_configure_storage_location():
-#     ...
+#     ...