code: def init_spark():
      # Start Spark schema -------------------------------------------------
      from pyspark.sql import SparkSession
  
      spark = SparkSession.builder.appName("allE2ETest").getOrCreate()
      createSchema.init_spark_schema(
          spark, Settings.data["TestSettings"]["dataDirectory"]
      )
      createSchema.init_spark_schema(
          spark,
          Settings.data["TestSettings"]["dataDirectory"],
          smiles_test=True,
          fileSchemaType=DataType.PARQUET,
      )
  
      return spark
  
imports: import copy
  import os
  from blazingsql import BlazingContext, DataType
  from dask.distributed import Client
  from dask_cuda import LocalCUDACluster
  from dask_cuda.utils import CPUAffinity, get_cpu_affinity
  from Configuration import ExecutionMode
  from Configuration import Settings
  from DataBase import createSchema
label_desc: Use image node_id 7 for calling a global function with example usage: init_spark() and returns: spark