File tree Expand file tree Collapse file tree 2 files changed +6
-5
lines changed Expand file tree Collapse file tree 2 files changed +6
-5
lines changed Original file line number Diff line number Diff line change 8
8
from pandas import DataFrame
9
9
10
10
if TYPE_CHECKING :
11
- from pyiceberg .catalog import Catalog # noqa: TC004
11
+ from pyiceberg .catalog import Catalog
12
12
13
13
14
14
def _get_catalog (
15
15
catalog_name : str | None , catalog_properties : dict [str , Any ] | None
16
- ) -> Catalog :
16
+ ) -> " Catalog" :
17
17
pyiceberg_catalog = import_optional_dependency ("pyiceberg.catalog" )
18
18
if catalog_properties is None :
19
19
catalog_properties = {}
Original file line number Diff line number Diff line change @@ -185,10 +185,11 @@ def test_write_existing_table(self, catalog):
185
185
)
186
186
new = pd .DataFrame (
187
187
{
188
- "A" : [4 , 5 ],
189
- "B" : ["bar " , "foobar " ],
188
+ "A" : [1 , 2 , 3 ],
189
+ "B" : ["foo " , "foo" , "foo " ],
190
190
}
191
191
)
192
+ expected = pd .concat ([original , new ], ignore_index = True )
192
193
new .to_iceberg (
193
194
"ns.my_table" ,
194
195
catalog_properties = {"uri" : catalog .uri },
@@ -198,4 +199,4 @@ def test_write_existing_table(self, catalog):
198
199
"ns.my_table" ,
199
200
catalog_properties = {"uri" : catalog .uri },
200
201
)
201
- tm .assert_frame_equal (result , pd . concat ([ original , new ]) )
202
+ tm .assert_frame_equal (result , expected )
You can’t perform that action at this time.
0 commit comments