Skip to content

Commit

Permalink
Remove the test that looks for exception: pyarrow==14 now handles thi…
Browse files Browse the repository at this point in the history
…s conversion.
  • Loading branch information
tvalentyn committed Sep 13, 2023
1 parent c03a273 commit 4a996ce
Showing 1 changed file with 0 additions and 12 deletions.
12 changes: 0 additions & 12 deletions sdks/python/apache_beam/io/parquetio_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -333,18 +333,6 @@ def test_write_batched_display_data(self):
]
hc.assert_that(dd.items, hc.contains_inanyorder(*expected_items))

def test_sink_transform_int96(self):
with tempfile.NamedTemporaryFile() as dst:
path = dst.name
# pylint: disable=c-extension-no-member
with self.assertRaises(pl.ArrowInvalid):
# Should throw an error "ArrowInvalid: Casting from timestamp[ns] to
# timestamp[us] would lose data"
with TestPipeline() as p:
_ = p \
| Create(self.RECORDS) \
| WriteToParquet(
path, self.SCHEMA96, num_shards=1, shard_name_template='')

def test_sink_transform(self):
with TemporaryDirectory() as tmp_dirname:
Expand Down

0 comments on commit 4a996ce

Please sign in to comment.