from pyspark.sql import SparkS
ession
import os


def get_spark_session(app_name = "spark_app"):
    master = os.environ["SPARK_MASTER"]
    spark = SparkSession.builder.\
        appName(app_name).\
        master(mast
er).\
        getOrCreate()
    return spark
