Skip to content

Commit 3f0a063

Browse files
committed
fix(lake): prefix should be underscore
1 parent b54d421 commit 3f0a063

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

servc/svc/com/storage/lake.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ def _get_table_name(self) -> str:
4545
name_w_medallion = self._table
4646
else:
4747
name_w_medallion = "".join(
48-
[self._table["medallion"].value, "-", self._table["name"]]
48+
[self._table["medallion"].value, "_", self._table["name"]]
4949
)
5050

5151
return ".".join([schema, name_w_medallion])

tests/lake/test_iceberg.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ def test_connect(self):
4848
self.assertTrue(self.iceberg.isOpen)
4949

5050
def test_name(self):
51-
self.assertEqual(self.iceberg.tablename, "default.bronze-test")
51+
self.assertEqual(self.iceberg.tablename, "default.bronze_test")
5252

5353
def test_insert(self):
5454
self.iceberg.overwrite([])
@@ -114,7 +114,7 @@ def test_load_from_catalog(self):
114114
self.iceberg.insert([{"date": "2021-01-01", "some_int": 1}])
115115
orig_data = self.iceberg.read(["date"]).to_pylist()
116116

117-
iceberg = IceBerg(config, "default.bronze-test")
117+
iceberg = IceBerg(config, "default.bronze_test")
118118
iceberg._connect()
119119
self.assertTrue(iceberg.isOpen)
120120

0 commit comments

Comments
 (0)