We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a8a36c4 commit 85b4403Copy full SHA for 85b4403
1 file changed
sqlmesh/core/engine_adapter/databricks.py
@@ -144,7 +144,7 @@ def get_current_catalog(self) -> t.Optional[str]:
144
145
try:
146
# Note: Spark 3.4+ Only API
147
- return super().get_current_catalog()
+ return self.spark.catalog.currentCatalog()
148
except (Py4JError, SparkConnectGrpcException):
149
pass
150
result = self.fetchone(exp.select(self.CURRENT_CATALOG_EXPRESSION))
@@ -164,7 +164,7 @@ def set_current_catalog(self, catalog_name: str) -> None:
164
165
166
167
- super().set_current_catalog(catalog_name)
+ self.spark.catalog.setCurrentCatalog(catalog_name)
168
169
170
0 commit comments