Skip to content

Update CHANGES to mention extras changes (#36875)

Sign in for the full log view
GitHub Actions / Test Results failed Nov 26, 2025 in 0s

1 fail, 262 skipped, 3 958 pass in 21m 32s

    4 files      4 suites   21m 32s ⏱️
4 221 tests 3 958 ✅ 262 💤 1 ❌
8 409 runs  7 467 ✅ 941 💤 1 ❌

Results for commit c2303be.

Annotations

Check warning on line 0 in apache_beam.yaml.yaml_transform_test.YamlTransformE2ETest

See this annotation in the file changed.

@github-actions github-actions / Test Results

1 out of 2 runs failed: test_csv_to_json (apache_beam.yaml.yaml_transform_test.YamlTransformE2ETest)

sdks/python/test-suites/tox/py311/build/srcs/sdks/python/pytest_py311.xml [took 3s]
Raw output
AssertionError: DataFrame are different

DataFrame shape mismatch
[left]:  (3, 2)
[right]: (1, 2)
self = <apache_beam.yaml.yaml_transform_test.YamlTransformE2ETest testMethod=test_csv_to_json>

    def test_csv_to_json(self):
      try:
        import pandas as pd
      except ImportError:
        raise unittest.SkipTest('Pandas not available.')
    
      with tempfile.TemporaryDirectory() as tmpdir:
        data = pd.DataFrame([
            {
                'label': '11a', 'rank': 0
            },
            {
                'label': '37a', 'rank': 1
            },
            {
                'label': '389a', 'rank': 2
            },
        ])
        input = os.path.join(tmpdir, 'input.csv')
        output = os.path.join(tmpdir, 'output.json')
        data.to_csv(input, index=False)
    
        with beam.Pipeline() as p:
          result = p | YamlTransform(
              '''
              type: chain
              transforms:
                - type: ReadFromCsv
                  config:
                      path: %s
                - type: WriteToJson
                  config:
                      path: %s
                  num_shards: 1
              ''' % (repr(input), repr(output)))
    
        output_shard = list(glob.glob(output + "*"))[0]
        result = pd.read_json(
            output_shard, orient='records',
            lines=True).sort_values('rank').reindex()
>       pd.testing.assert_frame_equal(data, result)
E       AssertionError: DataFrame are different
E       
E       DataFrame shape mismatch
E       [left]:  (3, 2)
E       [right]: (1, 2)

apache_beam/yaml/yaml_transform_test.py:266: AssertionError