File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change 4646import boto3
4747import pytest
4848from moto import mock_aws
49- from pyspark .sql import SparkSession
5049
5150from pyiceberg import schema
5251from pyiceberg .catalog import Catalog , load_catalog
8685if TYPE_CHECKING :
8786 import pyarrow as pa
8887 from moto .server import ThreadedMotoServer # type: ignore
88+ from pyspark .sql import SparkSession
8989
9090 from pyiceberg .io .pyarrow import PyArrowFileIO
9191
@@ -1954,9 +1954,10 @@ def session_catalog() -> Catalog:
19541954
19551955
19561956@pytest .fixture (scope = "session" )
1957- def spark () -> SparkSession :
1957+ def spark () -> " SparkSession" :
19581958 import importlib .metadata
1959- import os
1959+
1960+ from pyspark .sql import SparkSession
19601961
19611962 spark_version = "." .join (importlib .metadata .version ("pyspark" ).split ("." )[:2 ])
19621963 scala_version = "2.12"
You can’t perform that action at this time.
0 commit comments