Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
07-17-2024 09:27 AM
You could use Fixtures for SparkSession something like below
import pytest
from pyspark.sql import SparkSession
@pytest.fixture(scope="session") # Consider "function" for reuse within a test function
def spark_session():
spark = SparkSession.builder.appName("test").getOrCreate()
yield spark
spark.stop()