Skip to content

Commit 52e1fc8

Browse files
minor change
1 parent d179a91 commit 52e1fc8

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

flights/flights-liquibase/tests/unit_transforms/test_flight_transforms.py

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -5,16 +5,17 @@
55

66
@pytest.fixture(scope="module")
77
def spark_session():
8-
try:
9-
from databricks.connect import DatabricksSession
10-
if os.environ.get("DBCONNECT_SERVERLESS", "false").lower() == "true":
11-
return DatabricksSession.builder.serverless(True).getOrCreate()
8+
#try:
9+
# from databricks.connect import DatabricksSession
10+
if os.environ.get("DBCONNECT_SERVERLESS", "false").lower() == "true":
11+
return DatabricksSession.builder.serverless(True).getOrCreate()
1212
# else:
1313
# return DatabricksSession.builder.getOrCreate()
1414
# except (ValueError, RuntimeError):
1515
# from databricks.connect import DatabricksSession
1616
# return DatabricksSession.builder.profile("unit_tests").getOrCreate()
17-
except (ImportError, ValueError, RuntimeError):
17+
#except (ImportError, ValueError, RuntimeError):
18+
else:
1819
print("No Databricks Connect, build and return local SparkSession")
1920
from pyspark.sql import SparkSession
2021
return SparkSession.builder.getOrCreate()

0 commit comments

Comments
 (0)