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 46
46
import boto3
47
47
import pytest
48
48
from moto import mock_aws
49
- from pyspark .sql import SparkSession
50
49
51
50
from pyiceberg import schema
52
51
from pyiceberg .catalog import Catalog , load_catalog
86
85
if TYPE_CHECKING :
87
86
import pyarrow as pa
88
87
from moto .server import ThreadedMotoServer # type: ignore
88
+ from pyspark .sql import SparkSession
89
89
90
90
from pyiceberg .io .pyarrow import PyArrowFileIO
91
91
@@ -1954,9 +1954,10 @@ def session_catalog() -> Catalog:
1954
1954
1955
1955
1956
1956
@pytest .fixture (scope = "session" )
1957
- def spark () -> SparkSession :
1957
+ def spark () -> " SparkSession" :
1958
1958
import importlib .metadata
1959
- import os
1959
+
1960
+ from pyspark .sql import SparkSession
1960
1961
1961
1962
spark_version = "." .join (importlib .metadata .version ("pyspark" ).split ("." )[:2 ])
1962
1963
scala_version = "2.12"
You can’t perform that action at this time.
0 commit comments