Skip to content

Commit

Permalink
[#153] Add a test for the default Spark app name
Browse files Browse the repository at this point in the history
  • Loading branch information
riley-harper committed Oct 9, 2024
1 parent 5171c25 commit 740f50a
Showing 1 changed file with 16 additions and 0 deletions.
16 changes: 16 additions & 0 deletions hlink/tests/spark_connection_test.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,16 @@
from pathlib import Path
import sys

from hlink.spark.session import SparkConnection


def test_app_name_defaults_to_linking(tmp_path: Path) -> None:
derby_dir = tmp_path / "derby"
warehouse_dir = tmp_path / "warehouse"
tmp_dir = tmp_path / "tmp"
connection = SparkConnection(
derby_dir, warehouse_dir, tmp_dir, sys.executable, "test"
)
spark = connection.local(cores=1, executor_memory="1G")
app_name = spark.conf.get("spark.app.name")
assert app_name == "linking"

0 comments on commit 740f50a

Please sign in to comment.