如何在另一个模块中使用相同的spark会话

# spark_manager.py
from pyspark.sql import SparkSession

class SparkManager:
    _instance = None

    @staticmethod
    def get_spark_session():
        if SparkManager._instance is None:
            SparkManager._instance = SparkSession.builder \
                .appName("example") \
                .master("local[*]") \
                .getOrCreate()
        return SparkManager._instance

# module1.py
from spark_manager import SparkManager

spark = SparkManager.get_spark_session()
# 使用spark进行操作

# module2.py
from spark_manager import SparkManager

spark = SparkManager.get_spark_session()
# 使用spark进行操作

# conftest.py
import pytest
from pyspark.sql import SparkSession

@pytest.fixture(scope="session")
def spark_session():
    spark = SparkSession.builder \
        .appName("example") \
        .master("local[*]") \
        .getOrCreate()
    yield spark
    spark.stop()

# test_module1.py
def test_example(spark_session):
    # 使用spark_session进行测试
    pass

# test_module2.py
def test_example(spark_session):
    # 使用spark_session进行测试
    pass

# spark_manager.py
class SparkManager:
    _instance = None

    @staticmethod
    def get_spark_session():
        if SparkManager._instance is None:
            SparkManager._instance = SparkSession.builder \
                .appName("example") \
                .master("local[*]") \
                .getOrCreate()
        return SparkManager._instance

    @staticmethod
    def stop_spark_session():
        if SparkManager._instance is not None:
            SparkManager._instance.stop()
            SparkManager._instance = None

# main.py
from spark_manager import SparkManager

# 应用程序逻辑

SparkManager.stop_spark_session()

# spark_manager.py
class SparkManager:
    _instance = None

    @staticmethod
    def get_spark_session():
        if SparkManager._instance is None:
            SparkManager._instance = SparkSession.builder \
                .appName("example") \
                .master("local[*]") \
                .config("spark.some.config.option", "some-value") \
                .getOrCreate()
        return SparkManager._instance