make lint

Author: NikitaMatskevich

pyiceberg/io/__init__.py

@@ -84,8 +84,8 @@
 ADLS_ACCOUNT_HOST = "adls.account-host"
 ADLS_BLOB_STORAGE_AUTHORITY = "adls.blob-storage-authority"
 ADLS_DFS_STORAGE_AUTHORITY = "adls.dfs-storage-authority"
-ADLS_BLOB_STORAGE_SCHEME = "adls.blob-storage-scheme",
-ADLS_DFS_STORAGE_SCHEME = "adls.dfs-storage-scheme",
+ADLS_BLOB_STORAGE_SCHEME = "adls.blob-storage-scheme"
+ADLS_DFS_STORAGE_SCHEME = "adls.dfs-storage-scheme"
 GCS_TOKEN = "gcs.oauth2.token"
 GCS_TOKEN_EXPIRES_AT_MS = "gcs.oauth2.token-expires-at"
 GCS_PROJECT_ID = "gcs.project-id"

pyiceberg/io/pyarrow.py

@@ -85,11 +85,11 @@
 )
 from pyiceberg.expressions.visitors import visit as boolean_expression_visit
 from pyiceberg.io import (
-    ADLS_ACCOUNT_NAME,
     ADLS_ACCOUNT_KEY,
+    ADLS_ACCOUNT_NAME,
     ADLS_BLOB_STORAGE_AUTHORITY,
-    ADLS_DFS_STORAGE_AUTHORITY,
     ADLS_BLOB_STORAGE_SCHEME,
+    ADLS_DFS_STORAGE_AUTHORITY,
     ADLS_DFS_STORAGE_SCHEME,
     ADLS_SAS_TOKEN,
     AWS_ACCESS_KEY_ID,

tests/conftest.py

@@ -52,16 +52,16 @@
 from pyiceberg.catalog.noop import NoopCatalog
 from pyiceberg.expressions import BoundReference
 from pyiceberg.io import (
-    GCS_PROJECT_ID,
-    GCS_SERVICE_HOST,
-    GCS_TOKEN,
-    GCS_TOKEN_EXPIRES_AT_MS,
-    ADLS_ACCOUNT_NAME,
     ADLS_ACCOUNT_KEY,
+    ADLS_ACCOUNT_NAME,
     ADLS_BLOB_STORAGE_AUTHORITY,
-    ADLS_DFS_STORAGE_SCHEME,
     ADLS_BLOB_STORAGE_SCHEME,
     ADLS_DFS_STORAGE_AUTHORITY,
+    ADLS_DFS_STORAGE_SCHEME,
+    GCS_PROJECT_ID,
+    GCS_SERVICE_HOST,
+    GCS_TOKEN,
+    GCS_TOKEN_EXPIRES_AT_MS,
     fsspec,
     load_file_io,
 )
@@ -355,7 +355,7 @@ def table_schema_with_all_types() -> Schema:
 
 
 @pytest.fixture(params=["abfss", "wasbs"])
-def adls_scheme(request):
+def adls_scheme(request: pytest.FixtureRequest) -> str:
     return request.param
 
 
@@ -2120,7 +2120,7 @@ def adls_fsspec_fileio(request: pytest.FixtureRequest) -> Generator[FsspecFileIO
 
 
 @pytest.fixture
-def pyarrow_fileio_gcs(request: pytest.FixtureRequest) -> 'PyArrowFileIO':
+def pyarrow_fileio_gcs(request: pytest.FixtureRequest) -> "PyArrowFileIO":
     from pyiceberg.io.pyarrow import PyArrowFileIO
 
     properties = {
@@ -2135,10 +2135,11 @@ def pyarrow_fileio_gcs(request: pytest.FixtureRequest) -> 'PyArrowFileIO':
 @pytest.fixture
 def pyarrow_fileio_adls(request: pytest.FixtureRequest) -> Generator[Any, None, None]:
     from azure.storage.blob import BlobServiceClient
+
     from pyiceberg.io.pyarrow import PyArrowFileIO
 
     azurite_url = request.config.getoption("--adls.endpoint")
-    azurite_scheme, azurite_authority = azurite_url.split('://', 1)
+    azurite_scheme, azurite_authority = azurite_url.split("://", 1)
 
     azurite_account_name = request.config.getoption("--adls.account-name")
     azurite_account_key = request.config.getoption("--adls.account-key")

tests/io/test_pyarrow.py

@@ -1956,7 +1956,7 @@ def test_checking_if_a_file_exists_adls(pyarrow_fileio_adls: PyArrowFileIO, adls
 
 
 @pytest.mark.adls
-#@pytest.mark.skip(reason="Open issue on Arrow: https://github.com/apache/arrow/issues/36993")
+# @pytest.mark.skip(reason="Open issue on Arrow: https://github.com/apache/arrow/issues/36993")
 def test_closing_a_file_adls(pyarrow_fileio_adls: PyArrowFileIO, adls_scheme: str) -> None:
     """Test closing an output file and input file"""
     filename = str(uuid4())