fix: remove import that forces pyspark

tobymao · tobymao · commit d172131cc5b8 · 2024-04-11T21:24:09.000-07:00
diff --git a/sqlmesh/core/engine_adapter/spark.py b/sqlmesh/core/engine_adapter/spark.py
@@ -22,7 +22,6 @@
     SourceQuery,
     set_catalog,
 )
-from sqlmesh.engines.spark.db_api.spark_session import SparkSessionConnection
 from sqlmesh.utils import classproperty
 from sqlmesh.utils.errors import SQLMeshError
 
@@ -37,6 +36,7 @@
         Query,
     )
     from sqlmesh.core.engine_adapter.base import QueryOrDF
+    from sqlmesh.engines.spark.db_api.spark_session import SparkSessionConnection
 
 
 logger = logging.getLogger(__name__)

Original file line number	Diff line number	Diff line change
`@@ -22,7 +22,6 @@`
`22`	`22`	`SourceQuery,`
`23`	`23`	`set_catalog,`
`24`	`24`	`)`
`25`		`-from sqlmesh.engines.spark.db_api.spark_session import SparkSessionConnection`
`26`	`25`	`from sqlmesh.utils import classproperty`
`27`	`26`	`from sqlmesh.utils.errors import SQLMeshError`
`28`	`27`
`@@ -37,6 +36,7 @@`
`37`	`36`	`Query,`
`38`	`37`	`)`
`39`	`38`	`from sqlmesh.core.engine_adapter.base import QueryOrDF`
	`39`	`+ from sqlmesh.engines.spark.db_api.spark_session import SparkSessionConnection`
`40`	`40`
`41`	`41`
`42`	`42`	`logger = logging.getLogger(__name__)`