Skip to content

Commit a5dcef9

Browse files
fix: clarify Spark seeder pyhive dependency
Co-Authored-By: Itamar Hartstein <haritamar@gmail.com>
1 parent becc9a1 commit a5dcef9

1 file changed

Lines changed: 6 additions & 1 deletion

File tree

  • tests/e2e_dbt_project/external_seeders

tests/e2e_dbt_project/external_seeders/spark.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,12 @@ def load(self) -> None:
2929
f"(schema={seed_schema}) ==="
3030
)
3131

32-
from pyhive import hive
32+
try:
33+
from pyhive import hive
34+
except ImportError as e:
35+
raise RuntimeError(
36+
"pyhive is required for SparkExternalSeeder. Install dbt-spark[PyHive] (CI does this automatically)."
37+
) from e
3338

3439
host = os.environ.get("SPARK_HOST", "127.0.0.1")
3540
port = int(os.environ.get("SPARK_PORT", "10000"))

0 commit comments

Comments
 (0)