Skip to content

Commit

Permalink
Remove excessive logging in test. (#31715)
Browse files Browse the repository at this point in the history
  • Loading branch information
robertwb authored Jun 28, 2024
1 parent 9bdcb67 commit c3756c0
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions sdks/python/apache_beam/io/parquetio_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -410,9 +410,8 @@ def test_schema_read_write(self):
rows = [beam.Row(a=1, b='x'), beam.Row(a=2, b='y')]
stable_repr = lambda row: json.dumps(row._asdict())
with TestPipeline() as p:
_ = p | Create(rows) | WriteToParquet(path) | beam.Map(print)
_ = p | Create(rows) | WriteToParquet(path)
with TestPipeline() as p:
# json used for stable sortability
readback = (
p
| ReadFromParquet(path + '*', as_rows=True)
Expand Down

0 comments on commit c3756c0

Please sign in to comment.