Source code for dagster_spark.types

from dagster import Enum, EnumValue

SparkDeployModeCluster = EnumValue("cluster")
SparkDeployModeClient = EnumValue("client")
SparkDeployMode = Enum(
    name="SparkDeployMode", enum_values=[SparkDeployModeCluster, SparkDeployModeClient]
)


class SparkSolidError(Exception):
    pass


[docs]class SparkOpError(SparkSolidError):
    pass