Skip to content
PreCommit Python

Enable prism by default (where supported) #26666

Sign in to view logs

Enable prism by default (where supported)

Enable prism by default (where supported) #26666

GitHub Actions / Test Results failed Apr 11, 2025 in 0s

11 fail, 72 skipped, 790 pass in 14m 14s

  2 files  +  2    2 suites  +2   14m 14s ⏱️ + 14m 14s
873 tests +873  790 ✅ +790  72 💤 +72  11 ❌ +11 
875 runs  +875  790 ✅ +790  74 💤 +74  11 ❌ +11 

Results for commit 3233b69. ± Comparison against earlier commit e28e463.

Annotations

Check warning on line 0 in apache_beam.transforms.ptransform_test.PTransformTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_tuple_twice (apache_beam.transforms.ptransform_test.PTransformTest) failed 

sdks/python/test-suites/tox/py39/build/srcs/sdks/python/pytest_py39-cloud.xml [took 10s]
Raw output 
AssertionError: Lists differ: [1, 1, 2, 2, 4, 4, 8, 8] != [1, 2, 4, 8]

First differing element 1:
1
2

First list contains 4 additional elements.
First extra element 4:
4

- [1, 1, 2, 2, 4, 4, 8, 8]
+ [1, 2, 4, 8]
self = <apache_beam.transforms.ptransform_test.PTransformTest testMethod=test_tuple_twice>

    def test_tuple_twice(self):
      class Duplicate(PTransform):
        def expand(self, pcoll):
          return pcoll, pcoll
    
      res1, res2 = [1, 2, 4, 8] | Duplicate()
>     self.assertEqual(sorted(res1), [1, 2, 4, 8])
E     AssertionError: Lists differ: [1, 1, 2, 2, 4, 4, 8, 8] != [1, 2, 4, 8]
E     
E     First differing element 1:
E     1
E     2
E     
E     First list contains 4 additional elements.
E     First extra element 4:
E     4
E     
E     - [1, 1, 2, 2, 4, 4, 8, 8]
E     + [1, 2, 4, 8]

apache_beam/transforms/ptransform_test.py:930: AssertionError

Check warning on line 0 in apache_beam.transforms.core_test.ExceptionHandlingTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_handles_callbacks (apache_beam.transforms.core_test.ExceptionHandlingTest) failed 

sdks/python/test-suites/tox/py39/build/srcs/sdks/python/pytest_py39-cloud.xml [took 16s]
Raw output 
AssertionError: 'random contentrandom content' != 'random content'
- random contentrandom content
+ random content
self = <apache_beam.transforms.core_test.ExceptionHandlingTest testMethod=test_handles_callbacks>

    def test_handles_callbacks(self):
      with tempfile.TemporaryDirectory() as tmp_dirname:
        tmp_path = os.path.join(tmp_dirname, 'tmp_filename')
        file_contents = 'random content'
    
        def failure_callback(e, el):
          if type(e) is not ValueError:
            raise Exception(f'Failed to pass in correct exception, received {e}')
          if el != 'foobar':
            raise Exception(f'Failed to pass in correct element, received {el}')
          f = open(tmp_path, "a")
          logging.warning(tmp_path)
          f.write(file_contents)
          f.close()
    
        with beam.Pipeline() as pipeline:
          good, bad = (
            pipeline | beam.Create(['abc', 'bcd', 'foo', 'bar', 'foobar'])
            | beam.ParDo(TestDoFn9()).with_exception_handling(
              on_failure_callback=failure_callback)
          )
          bad_elements = bad | beam.Keys()
          assert_that(good, equal_to(['abc', 'bcd', 'foo', 'bar']), 'good')
          assert_that(bad_elements, equal_to(['foobar']), 'bad')
        with open(tmp_path) as f:
          s = f.read()
>         self.assertEqual(s, file_contents)
E         AssertionError: 'random contentrandom content' != 'random content'
E         - random contentrandom content
E         + random content

apache_beam/transforms/core_test.py:257: AssertionError

Check warning on line 0 in apache_beam.transforms.ptransform_test.PTransformTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_apply_to_crazy_pvaluish (apache_beam.transforms.ptransform_test.PTransformTest) failed 

sdks/python/test-suites/tox/py39/build/srcs/sdks/python/pytest_py39-cloud.xml [took 11s]
Raw output 
AssertionError: Lists differ: [1, 2, 3, 4, 5, 6, 7, 8] != [1, 1, 2, 2, 3, 3, 4, 4, 5, 5, 6, 6, 7, 7, 8, 8]

First differing element 1:
2
1

Second list contains 8 additional elements.
First extra element 8:
5

- [1, 2, 3, 4, 5, 6, 7, 8]
+ [1, 1, 2, 2, 3, 3, 4, 4, 5, 5, 6, 6, 7, 7, 8, 8]
self = <apache_beam.transforms.ptransform_test.PTransformTest testMethod=test_apply_to_crazy_pvaluish>

    def test_apply_to_crazy_pvaluish(self):
      class NestedFlatten(PTransform):
        """A PTransform taking and returning nested PValueish.
    
        Takes as input a list of dicts, and returns a dict with the corresponding
        values flattened.
        """
        def _extract_input_pvalues(self, pvalueish):
          pvalueish = list(pvalueish)
          return pvalueish, sum([list(p.values()) for p in pvalueish], [])
    
        def expand(self, pcoll_dicts):
          keys = reduce(operator.or_, [set(p.keys()) for p in pcoll_dicts])
          res = {}
          for k in keys:
            res[k] = [p[k] for p in pcoll_dicts if k in p] | k >> beam.Flatten()
          return res
    
      res = [{
          'a': [1, 2, 3]
      }, {
          'a': [4, 5, 6], 'b': ['x', 'y', 'z']
      }, {
          'a': [7, 8], 'b': ['x', 'y'], 'c': []
      }] | NestedFlatten()
      self.assertEqual(3, len(res))
>     self.assertEqual([1, 2, 3, 4, 5, 6, 7, 8], sorted(res['a']))
E     AssertionError: Lists differ: [1, 2, 3, 4, 5, 6, 7, 8] != [1, 1, 2, 2, 3, 3, 4, 4, 5, 5, 6, 6, 7, 7, 8, 8]
E     
E     First differing element 1:
E     2
E     1
E     
E     Second list contains 8 additional elements.
E     First extra element 8:
E     5
E     
E     - [1, 2, 3, 4, 5, 6, 7, 8]
E     + [1, 1, 2, 2, 3, 3, 4, 4, 5, 5, 6, 6, 7, 7, 8, 8]

apache_beam/transforms/ptransform_test.py:904: AssertionError

Check warning on line 0 in apache_beam.transforms.ptransform_test.PTransformTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_apply_to_list (apache_beam.transforms.ptransform_test.PTransformTest) failed 

sdks/python/test-suites/tox/py39/build/srcs/sdks/python/pytest_py39-cloud.xml [took 17s]
Raw output 
AssertionError: Element counts were not equal:
First has 1, Second has 2:  1
self = <apache_beam.transforms.ptransform_test.PTransformTest testMethod=test_apply_to_list>

    def test_apply_to_list(self):
      self.assertCountEqual([1, 2, 3],
                            [0, 1, 2] | 'AddOne' >> beam.Map(lambda x: x + 1))
>     self.assertCountEqual([1],
                            [0, 1, 2] | 'Odd' >> beam.Filter(lambda x: x % 2))
E     AssertionError: Element counts were not equal:
E     First has 1, Second has 2:  1

apache_beam/transforms/ptransform_test.py:859: AssertionError

Check warning on line 0 in apache_beam.transforms.ptransform_test.PTransformTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_multi_input_ptransform (apache_beam.transforms.ptransform_test.PTransformTest) failed 

sdks/python/test-suites/tox/py39/build/srcs/sdks/python/pytest_py39-cloud.xml [took 7s]
Raw output 
AssertionError: Lists differ: [1, 2, 3] != [1, 1, 2, 2, 3, 3]

First differing element 1:
2
1

Second list contains 3 additional elements.
First extra element 3:
2

- [1, 2, 3]
+ [1, 1, 2, 2, 3, 3]
self = <apache_beam.transforms.ptransform_test.PTransformTest testMethod=test_multi_input_ptransform>

    def test_multi_input_ptransform(self):
      class DisjointUnion(PTransform):
        def expand(self, pcollections):
          return (
              pcollections
              | beam.Flatten()
              | beam.Map(lambda x: (x, None))
              | beam.GroupByKey()
              | beam.Map(lambda kv: kv[0]))
    
>     self.assertEqual([1, 2, 3], sorted(([1, 2], [2, 3]) | DisjointUnion()))
E     AssertionError: Lists differ: [1, 2, 3] != [1, 1, 2, 2, 3, 3]
E     
E     First differing element 1:
E     2
E     1
E     
E     Second list contains 3 additional elements.
E     First extra element 3:
E     2
E     
E     - [1, 2, 3]
E     + [1, 1, 2, 2, 3, 3]

apache_beam/transforms/ptransform_test.py:876: AssertionError

Check warning on line 0 in apache_beam.transforms.combiners_test.CombineTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_top_key (apache_beam.transforms.combiners_test.CombineTest) failed 

sdks/python/test-suites/tox/py39/build/srcs/sdks/python/pytest_py39-cloud.xml [took 6s]
Raw output 
AssertionError: Lists differ: [['dddd', 'bbb', 'aa'], ['dddd', 'bbb', 'aa']] != [['dddd', 'bbb', 'aa']]

First list contains 1 additional elements.
First extra element 1:
['dddd', 'bbb', 'aa']

- [['dddd', 'bbb', 'aa'], ['dddd', 'bbb', 'aa']]
+ [['dddd', 'bbb', 'aa']]
self = <apache_beam.transforms.combiners_test.CombineTest testMethod=test_top_key>

    def test_top_key(self):
>     self.assertEqual(['aa', 'bbb', 'c', 'dddd'] | combine.Top.Of(3, key=len),
                       [['dddd', 'bbb', 'aa']])
E     AssertionError: Lists differ: [['dddd', 'bbb', 'aa'], ['dddd', 'bbb', 'aa']] != [['dddd', 'bbb', 'aa']]
E     
E     First list contains 1 additional elements.
E     First extra element 1:
E     ['dddd', 'bbb', 'aa']
E     
E     - [['dddd', 'bbb', 'aa'], ['dddd', 'bbb', 'aa']]
E     + [['dddd', 'bbb', 'aa']]

apache_beam/transforms/combiners_test.py:190: AssertionError

Check warning on line 0 in apache_beam.transforms.ptransform_test.PTransformTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_named_tuple (apache_beam.transforms.ptransform_test.PTransformTest) failed 

sdks/python/test-suites/tox/py39/build/srcs/sdks/python/pytest_py39-cloud.xml [took 6s]
Raw output 
AssertionError: MinMax(min=[1, 1], max=[8, 8]) != MinMax(min=[1], max=[8])
self = <apache_beam.transforms.ptransform_test.PTransformTest testMethod=test_named_tuple>

    def test_named_tuple(self):
      MinMax = collections.namedtuple('MinMax', ['min', 'max'])
    
      class MinMaxTransform(PTransform):
        def expand(self, pcoll):
          return MinMax(
              min=pcoll | beam.CombineGlobally(min).without_defaults(),
              max=pcoll | beam.CombineGlobally(max).without_defaults())
    
      res = [1, 2, 4, 8] | MinMaxTransform()
      self.assertIsInstance(res, MinMax)
>     self.assertEqual(res, MinMax(min=[1], max=[8]))
E     AssertionError: MinMax(min=[1, 1], max=[8, 8]) != MinMax(min=[1], max=[8])

apache_beam/transforms/ptransform_test.py:919: AssertionError

Check warning on line 0 in apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_eager_execution (apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase) failed 

sdks/python/test-suites/tox/py39/build/srcs/sdks/python/pytest_py39-cloud.xml [took 6s]
Raw output 
AssertionError: Lists differ: [2, 4, 6, 8] != [2, 4, 6, 8, 2, 4, 6, 8]

Second list contains 4 additional elements.
First extra element 4:
2

- [2, 4, 6, 8]
+ [2, 4, 6, 8, 2, 4, 6, 8]
self = <apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase testMethod=test_eager_execution>

    def test_eager_execution(self):
      doubled = [1, 2, 3, 4] | beam.Map(lambda x: 2 * x)
>     self.assertEqual([2, 4, 6, 8], doubled)
E     AssertionError: Lists differ: [2, 4, 6, 8] != [2, 4, 6, 8, 2, 4, 6, 8]
E     
E     Second list contains 4 additional elements.
E     First extra element 4:
E     2
E     
E     - [2, 4, 6, 8]
E     + [2, 4, 6, 8, 2, 4, 6, 8]

apache_beam/transforms/ptransform_test.py:2588: AssertionError

Check warning on line 0 in apache_beam.transforms.util_test.LogElementsTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_stdout_logs (apache_beam.transforms.util_test.LogElementsTest) failed 

sdks/python/test-suites/tox/py39/build/srcs/sdks/python/pytest_py39-cloud.xml [took 8s]
Raw output 
AssertionError: Received from stdout: prefix_event, timestamp='2022-10-01T00:00:00Z', window(start=2022-10-01T00:00:00Z, end=2022-10-01T00:01:00Z)
  prefix_event, timestamp='2022-10-02T00:00:00Z', window(start=2022-10-02T00:00:00Z, end=2022-10-02T00:01:00Z)
  prefix_event, timestamp='2022-10-01T00:00:00Z', window(start=2022-10-01T00:00:00Z, end=2022-10-01T00:01:00Z)
  prefix_event, timestamp='2022-10-02T00:00:00Z', window(start=2022-10-02T00:00:00Z, end=2022-10-02T00:01:00Z)
  
assert 'prefix_event...T00:01:00Z)\n' == 'prefix_event...T00:01:00Z)\n'
    prefix_event, timestamp='2022-10-01T00:00:00Z', window(start=2022-10-01T00:00:00Z, end=2022-10-01T00:01:00Z)
    prefix_event, timestamp='2022-10-02T00:00:00Z', window(start=2022-10-02T00:00:00Z, end=2022-10-02T00:01:00Z)
  + prefix_event, timestamp='2022-10-01T00:00:00Z', window(start=2022-10-01T00:00:00Z, end=2022-10-01T00:01:00Z)
  + prefix_event, timestamp='2022-10-02T00:00:00Z', window(start=2022-10-02T00:00:00Z, end=2022-10-02T00:01:00Z)
self = <apache_beam.transforms.util_test.LogElementsTest testMethod=test_stdout_logs>

    @pytest.mark.usefixtures("_capture_stdout_log")
    def test_stdout_logs(self):
>     assert self.captured_stdout == \
        ("prefix_event, timestamp='2022-10-01T00:00:00Z', "
         "window(start=2022-10-01T00:00:00Z, end=2022-10-01T00:01:00Z)\n"
         "prefix_event, timestamp='2022-10-02T00:00:00Z', "
         "window(start=2022-10-02T00:00:00Z, end=2022-10-02T00:01:00Z)\n"), \
        f'Received from stdout: {self.captured_stdout}'
E     AssertionError: Received from stdout: prefix_event, timestamp='2022-10-01T00:00:00Z', window(start=2022-10-01T00:00:00Z, end=2022-10-01T00:01:00Z)
E       prefix_event, timestamp='2022-10-02T00:00:00Z', window(start=2022-10-02T00:00:00Z, end=2022-10-02T00:01:00Z)
E       prefix_event, timestamp='2022-10-01T00:00:00Z', window(start=2022-10-01T00:00:00Z, end=2022-10-01T00:01:00Z)
E       prefix_event, timestamp='2022-10-02T00:00:00Z', window(start=2022-10-02T00:00:00Z, end=2022-10-02T00:01:00Z)
E       
E     assert 'prefix_event...T00:01:00Z)\n' == 'prefix_event...T00:01:00Z)\n'
E         prefix_event, timestamp='2022-10-01T00:00:00Z', window(start=2022-10-01T00:00:00Z, end=2022-10-01T00:01:00Z)
E         prefix_event, timestamp='2022-10-02T00:00:00Z', window(start=2022-10-02T00:00:00Z, end=2022-10-02T00:01:00Z)
E       + prefix_event, timestamp='2022-10-01T00:00:00Z', window(start=2022-10-01T00:00:00Z, end=2022-10-01T00:01:00Z)
E       + prefix_event, timestamp='2022-10-02T00:00:00Z', window(start=2022-10-02T00:00:00Z, end=2022-10-02T00:01:00Z)

apache_beam/transforms/util_test.py:1426: AssertionError

Check warning on line 0 in apache_beam.transforms.util_test.TeeTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_tee (apache_beam.transforms.util_test.TeeTest) failed 

sdks/python/test-suites/tox/py39/build/srcs/sdks/python/pytest_py39-cloud.xml [took 9s]
Raw output 
AssertionError: 2 != 1
self = <apache_beam.transforms.util_test.TeeTest testMethod=test_tee>

    def test_tee(self):
      # The imports here are to avoid issues with the class (and its attributes)
      # possibly being pickled rather than referenced.
      def cause_side_effect(element):
        importlib.import_module(__name__).TeeTest._side_effects[element] += 1
    
      def count_side_effects(element):
        return importlib.import_module(__name__).TeeTest._side_effects[element]
    
      with TestPipeline() as p:
        result = (
            p
            | beam.Create(['a', 'b', 'c'])
            | 'TeePTransform' >> beam.Tee(beam.Map(cause_side_effect))
            | 'TeeCallable' >> beam.Tee(
                lambda pcoll: pcoll | beam.Map(
                    lambda element: cause_side_effect('X' + element))))
        assert_that(result, equal_to(['a', 'b', 'c']))
    
>     self.assertEqual(count_side_effects('a'), 1)
E     AssertionError: 2 != 1

apache_beam/transforms/util_test.py:1916: AssertionError

Check warning on line 0 in apache_beam.transforms.util_test.WaitOnTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_find (apache_beam.transforms.util_test.WaitOnTest) failed 

sdks/python/test-suites/tox/py39/build/srcs/sdks/python/pytest_py39-cloud.xml [took 14s]
Raw output 
apache_beam.testing.util.BeamAssertException: Failed assert: [(None, 'x', 0), (None, 'x', 1)] == [(None, 'x', 8), (None, 'x', 9)], unexpected elements [(None, 'x', 8), (None, 'x', 9)], missing elements [(None, 'x', 0), (None, 'x', 1)] [while running 'x/Match']
>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1495: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:911: in apache_beam.runners.common.PerWindowInvoker.invoke_process
    self._invoke_process_per_window(
apache_beam/runners/common.py:1055: in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
    self.process_method(*args_for_process, **kwargs_for_process),
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py:2084: in <lambda>
    wrapper = lambda x, *args, **kwargs: [fn(x, *args, **kwargs)]
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

actual = [(None, 'x', 8), (None, 'x', 9)]
equals_fn = <function equal_to.<locals>._equal.<locals>.<lambda> at 0x787647b2f8b0>

    def _equal(actual, equals_fn=equals_fn):
      expected_list = list(expected)
    
      # Try to compare actual and expected by sorting. This fails with a
      # TypeError in Python 3 if different types are present in the same
      # collection. It can also raise false negatives for types that don't have
      # a deterministic sort order, like pyarrow Tables as of 0.14.1
      if not equals_fn:
        equals_fn = lambda e, a: e == a
        try:
          sorted_expected = sorted(expected)
          sorted_actual = sorted(actual)
          if sorted_expected == sorted_actual:
            return
        except TypeError:
          pass
      # Slower method, used in two cases:
      # 1) If sorted expected != actual, use this method to verify the inequality.
      #    This ensures we don't raise any false negatives for types that don't
      #    have a deterministic sort order.
      # 2) As a fallback if we encounter a TypeError in python 3. this method
      #    works on collections that have different types.
      unexpected = []
      for element in actual:
        found = False
        for i, v in enumerate(expected_list):
          if equals_fn(v, element):
            found = True
            expected_list.pop(i)
            break
        if not found:
          unexpected.append(element)
      if unexpected or expected_list:
        msg = 'Failed assert: %r == %r' % (expected, actual)
        if unexpected:
          msg = msg + ', unexpected elements %r' % unexpected
        if expected_list:
          msg = msg + ', missing elements %r' % expected_list
>       raise BeamAssertException(msg)
E       apache_beam.testing.util.BeamAssertException: Failed assert: [(None, 'x', 0), (None, 'x', 1)] == [(None, 'x', 8), (None, 'x', 9)], unexpected elements [(None, 'x', 8), (None, 'x', 9)], missing elements [(None, 'x', 0), (None, 'x', 1)]

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/testing/util.py:192: BeamAssertException

During handling of the above exception, another exception occurred:

self = <apache_beam.transforms.util_test.WaitOnTest testMethod=test_find>

    def test_find(self):
      # We need shared reference that survives pickling.
      def increment_global_counter():
        try:
          value = getattr(beam, '_WAIT_ON_TEST_COUNTER', 0)
          return value
        finally:
          setattr(beam, '_WAIT_ON_TEST_COUNTER', value + 1)
    
      def record(tag):
        return f'Record({tag})' >> beam.Map(
            lambda x: (x[0], tag, increment_global_counter()))
    
      with TestPipeline() as p:
        start = p | beam.Create([(None, ), (None, )])
        x = start | record('x')
        y = start | 'WaitForX' >> util.WaitOn(x) | record('y')
        z = start | 'WaitForY' >> util.WaitOn(y) | record('z')
        result = x | 'WaitForYZ' >> util.WaitOn(y, z) | record('result')
        assert_that(x, equal_to([(None, 'x', 0), (None, 'x', 1)]), label='x')
        assert_that(y, equal_to([(None, 'y', 2), (None, 'y', 3)]), label='y')
        assert_that(z, equal_to([(None, 'z', 4), (None, 'z', 5)]), label='z')
>       assert_that(
            result,
            equal_to([(None, 'result', 6), (None, 'result', 7)]),
            label='result')

apache_beam/transforms/util_test.py:1943: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/pipeline.py:644: in __exit__
    self.result = self.run()
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/testing/test_pipeline.py:115: in run
    result = super().run(
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/pipeline.py:591: in run
    return Pipeline.from_runner_api(
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/pipeline.py:618: in run
    return self.runner.run_pipeline(self, self._options)
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/direct/direct_runner.py:190: in run_pipeline
    return runner.run_pipeline(pipeline, options)
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py:196: in run_pipeline
    self._latest_run_result = self.run_via_runner_api(
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py:223: in run_via_runner_api
    return self.run_stages(stage_context, stages)
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py:470: in run_stages
    bundle_results = self._execute_bundle(
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py:795: in _execute_bundle
    self._run_bundle(
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py:1034: in _run_bundle
    result, splits = bundle_manager.process_bundle(
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py:1360: in process_bundle
    result_future = self._worker_handler.control_conn.push(process_bundle_req)
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/worker_handlers.py:386: in push
    response = self.worker.do_instruction(request)
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py:658: in do_instruction
    return getattr(self, request_type)(
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py:696: in process_bundle
    bundle_processor.process_bundle(instruction_id))
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py:1274: in process_bundle
    input_op_by_transform_id[element.transform_id].process_encoded(
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py:237: in process_encoded
    self.output(decoded_value)
apache_beam/runners/worker/operations.py:566: in apache_beam.runners.worker.operations.Operation.output
    def output(self, windowed_value, output_index=0):
apache_beam/runners/worker/operations.py:568: in apache_beam.runners.worker.operations.Operation.output
    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)
apache_beam/runners/worker/operations.py:259: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    def receive(self, windowed_value):
apache_beam/runners/worker/operations.py:262: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:949: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1497: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
apache_beam/runners/common.py:1585: in apache_beam.runners.common.DoFnRunner._reraise_augmented
    raise exn
apache_beam/runners/common.py:1495: in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
apache_beam/runners/common.py:683: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1680: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1793: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:262: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:949: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1497: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
apache_beam/runners/common.py:1585: in apache_beam.runners.common.DoFnRunner._reraise_augmented
    raise exn
apache_beam/runners/common.py:1495: in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
apache_beam/runners/common.py:683: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1680: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1793: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:262: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:949: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1497: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
apache_beam/runners/common.py:1585: in apache_beam.runners.common.DoFnRunner._reraise_augmented
    raise exn
apache_beam/runners/common.py:1495: in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
apache_beam/runners/common.py:683: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1680: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1793: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:262: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:949: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1497: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
apache_beam/runners/common.py:1606: in apache_beam.runners.common.DoFnRunner._reraise_augmented
    raise new_exn
apache_beam/runners/common.py:1495: in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
apache_beam/runners/common.py:911: in apache_beam.runners.common.PerWindowInvoker.invoke_process
    self._invoke_process_per_window(
apache_beam/runners/common.py:1055: in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
    self.process_method(*args_for_process, **kwargs_for_process),
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py:2084: in <lambda>
    wrapper = lambda x, *args, **kwargs: [fn(x, *args, **kwargs)]
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

actual = [(None, 'x', 8), (None, 'x', 9)]
equals_fn = <function equal_to.<locals>._equal.<locals>.<lambda> at 0x787647b2f8b0>

    def _equal(actual, equals_fn=equals_fn):
      expected_list = list(expected)
    
      # Try to compare actual and expected by sorting. This fails with a
      # TypeError in Python 3 if different types are present in the same
      # collection. It can also raise false negatives for types that don't have
      # a deterministic sort order, like pyarrow Tables as of 0.14.1
      if not equals_fn:
        equals_fn = lambda e, a: e == a
        try:
          sorted_expected = sorted(expected)
          sorted_actual = sorted(actual)
          if sorted_expected == sorted_actual:
            return
        except TypeError:
          pass
      # Slower method, used in two cases:
      # 1) If sorted expected != actual, use this method to verify the inequality.
      #    This ensures we don't raise any false negatives for types that don't
      #    have a deterministic sort order.
      # 2) As a fallback if we encounter a TypeError in python 3. this method
      #    works on collections that have different types.
      unexpected = []
      for element in actual:
        found = False
        for i, v in enumerate(expected_list):
          if equals_fn(v, element):
            found = True
            expected_list.pop(i)
            break
        if not found:
          unexpected.append(element)
      if unexpected or expected_list:
        msg = 'Failed assert: %r == %r' % (expected, actual)
        if unexpected:
          msg = msg + ', unexpected elements %r' % unexpected
        if expected_list:
          msg = msg + ', missing elements %r' % expected_list
>       raise BeamAssertException(msg)
E       apache_beam.testing.util.BeamAssertException: Failed assert: [(None, 'x', 0), (None, 'x', 1)] == [(None, 'x', 8), (None, 'x', 9)], unexpected elements [(None, 'x', 8), (None, 'x', 9)], missing elements [(None, 'x', 0), (None, 'x', 1)] [while running 'x/Match']

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/testing/util.py:192: BeamAssertException

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

72 skipped tests found 

There are 72 skipped tests, see "Raw output" for the full list of skipped tests.
Raw output 
apache_beam.transforms.combinefn_lifecycle_test.CombineFnLifecycleTest ‑ test_combine
apache_beam.transforms.combinefn_lifecycle_test.CombineFnLifecycleTest ‑ test_combining_value_state
apache_beam.transforms.combinefn_lifecycle_test.CombineFnLifecycleTest ‑ test_non_liftable_combine
apache_beam.transforms.deduplicate_test.DeduplicateTest ‑ test_deduplication_with_event_time
apache_beam.transforms.deduplicate_test.DeduplicateTest ‑ test_deduplication_with_processing_time
apache_beam.transforms.enrichment_handlers.bigquery_it_test.TestBigQueryEnrichmentIT ‑ test_bigquery_enrichment
apache_beam.transforms.enrichment_handlers.bigquery_it_test.TestBigQueryEnrichmentIT ‑ test_bigquery_enrichment_batched
apache_beam.transforms.enrichment_handlers.bigquery_it_test.TestBigQueryEnrichmentIT ‑ test_bigquery_enrichment_batched_multiple_fields
apache_beam.transforms.enrichment_handlers.bigquery_it_test.TestBigQueryEnrichmentIT ‑ test_bigquery_enrichment_with_condition_value_fn
apache_beam.transforms.enrichment_handlers.bigquery_it_test.TestBigQueryEnrichmentIT ‑ test_bigquery_enrichment_with_query_fn
apache_beam.transforms.enrichment_handlers.bigquery_it_test.TestBigQueryEnrichmentIT ‑ test_bigquery_enrichment_with_redis
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_bigtable_enrichment_with_lambda
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_bigtable_enrichment_with_redis
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_enrichment_with_bigtable
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_enrichment_with_bigtable_no_enrichment
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_enrichment_with_bigtable_row_filter
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_enrichment_with_bigtable_with_timestamp
apache_beam.transforms.enrichment_handlers.feast_feature_store_it_test
apache_beam.transforms.enrichment_handlers.feast_feature_store_test
apache_beam.transforms.enrichment_handlers.vertex_ai_feature_store_it_test.TestVertexAIFeatureStoreHandler ‑ test_feature_store_enrichment_with_redis
apache_beam.transforms.enrichment_handlers.vertex_ai_feature_store_it_test.TestVertexAIFeatureStoreHandler ‑ test_vertex_ai_feature_store_bigtable_serving_enrichment
apache_beam.transforms.enrichment_handlers.vertex_ai_feature_store_it_test.TestVertexAIFeatureStoreHandler ‑ test_vertex_ai_legacy_feature_store_enrichment
apache_beam.transforms.enrichment_it_test.TestEnrichment ‑ test_http_enrichment
apache_beam.transforms.enrichment_it_test.TestEnrichment ‑ test_http_enrichment_custom_join
apache_beam.transforms.external_it_test.ExternalTransformIT ‑ test_job_python_from_python_it
apache_beam.transforms.external_transform_provider_it_test.AutoGenerationScriptIT ‑ test_check_standard_external_transforms_config_in_sync
apache_beam.transforms.external_transform_provider_it_test.AutoGenerationScriptIT ‑ test_pretty_types
apache_beam.transforms.external_transform_provider_it_test.AutoGenerationScriptIT ‑ test_run_pipeline_with_generated_transform
apache_beam.transforms.external_transform_provider_it_test.AutoGenerationScriptIT ‑ test_script_fails_with_invalid_destinations
apache_beam.transforms.external_transform_provider_it_test.AutoGenerationScriptIT ‑ test_script_workflow
apache_beam.transforms.external_transform_provider_it_test.AutoGenerationScriptIT ‑ test_script_workflow_with_modified_transforms
apache_beam.transforms.external_transform_provider_it_test.AutoGenerationScriptIT ‑ test_script_workflow_with_skipped_transform
apache_beam.transforms.external_transform_provider_it_test.ExternalTransformProviderIT ‑ test_generate_sequence_signature_and_doc
apache_beam.transforms.external_transform_provider_it_test.ExternalTransformProviderIT ‑ test_run_generate_sequence
apache_beam.transforms.managed_iceberg_it_test.ManagedIcebergIT ‑ test_write_read_pipeline
apache_beam.transforms.periodicsequence_it_test.PeriodicSequenceIT ‑ test_periodicsequence_outputs_valid_watermarks_it
apache_beam.transforms.ptransform_test.DeadLettersTest_1 ‑ test_partial
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_agg
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_filter
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_generate_data
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_map
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_project
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_row
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_tagged_join
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_windowing_before_sql
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_zetasql_generate_data
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_discarding_early_fixed
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_early_late_sessions
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_fixed_default_late_data
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_fixed_drop_late_data_after_allowed_lateness
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_garbage_collection
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_known_late_data_no_watermark_hold_possible
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_known_late_data_watermark
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_earliest_1
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_early_late_sessions
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_garbage_collection
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_known_late_data_no_watermark_hold_possible
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_known_late_data_watermark
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_earliest_1
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_early_late_sessions
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_garbage_collection
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_known_late_data_no_watermark_hold_possible
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_known_late_data_watermark
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_earliest_1
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_cogroup_by_key
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_combine_globally
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_combine_per_key
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_flatten
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_group_by_key
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_multi_input_output_with_sideinput
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_partition
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_prefix

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

873 tests found (test 1 to 643) 

There are 873 tests, see "Raw output" for the list of tests 1 to 643.
Raw output 
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_BatchDoFn ‑ test_can_yield_batches
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_BatchDoFn ‑ test_get_input_batch_type
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_BatchDoFn ‑ test_get_output_batch_type
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_BatchDoFn ‑ test_process_batch_defined
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_BatchDoFn ‑ test_process_defined
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_BatchToElementDoFn ‑ test_can_yield_batches
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_BatchToElementDoFn ‑ test_get_input_batch_type
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_BatchToElementDoFn ‑ test_get_output_batch_type
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_BatchToElementDoFn ‑ test_process_batch_defined
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_BatchToElementDoFn ‑ test_process_defined
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_EitherDoFn ‑ test_can_yield_batches
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_EitherDoFn ‑ test_get_input_batch_type
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_EitherDoFn ‑ test_get_output_batch_type
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_EitherDoFn ‑ test_process_batch_defined
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_EitherDoFn ‑ test_process_defined
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_ElementDoFn ‑ test_can_yield_batches
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_ElementDoFn ‑ test_get_input_batch_type
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_ElementDoFn ‑ test_get_output_batch_type
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_ElementDoFn ‑ test_process_batch_defined
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_ElementDoFn ‑ test_process_defined
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_ElementToBatchDoFn ‑ test_can_yield_batches
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_ElementToBatchDoFn ‑ test_get_input_batch_type
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_ElementToBatchDoFn ‑ test_get_output_batch_type
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_ElementToBatchDoFn ‑ test_process_batch_defined
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_ElementToBatchDoFn ‑ test_process_defined
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_NoReturnAnnotation ‑ test_can_yield_batches
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_NoReturnAnnotation ‑ test_get_input_batch_type
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_NoReturnAnnotation ‑ test_get_output_batch_type
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_NoReturnAnnotation ‑ test_process_batch_defined
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_NoReturnAnnotation ‑ test_process_defined
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_OverrideTypeInference ‑ test_can_yield_batches
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_OverrideTypeInference ‑ test_get_input_batch_type
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_OverrideTypeInference ‑ test_get_output_batch_type
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_OverrideTypeInference ‑ test_process_batch_defined
apache_beam.transforms.batch_dofn_test.BatchDoFnParameterizedTest_OverrideTypeInference ‑ test_process_defined
apache_beam.transforms.batch_dofn_test.BatchDoFnTest ‑ test_batch_to_element_dofn_typehint
apache_beam.transforms.batch_dofn_test.BatchDoFnTest ‑ test_cant_infer_batchconverter_input_raises
apache_beam.transforms.batch_dofn_test.BatchDoFnTest ‑ test_cant_infer_batchconverter_output_raises
apache_beam.transforms.batch_dofn_test.BatchDoFnTest ‑ test_element_to_batch_dofn_typehint
apache_beam.transforms.batch_dofn_test.BatchDoFnTest ‑ test_map_pardo
apache_beam.transforms.batch_dofn_test.BatchDoFnTest ‑ test_mismatched_batch_producer_raises
apache_beam.transforms.batch_dofn_test.BatchDoFnTest ‑ test_mismatched_element_producer_raises
apache_beam.transforms.batch_dofn_test.BatchDoFnTest ‑ test_no_input_annotation_raises
apache_beam.transforms.batch_dofn_test.BatchDoFnTest ‑ test_unsupported_dofn_param_raises
apache_beam.transforms.combinefn_lifecycle_test.CombineFnLifecycleTest ‑ test_combine
apache_beam.transforms.combinefn_lifecycle_test.CombineFnLifecycleTest ‑ test_combining_value_state
apache_beam.transforms.combinefn_lifecycle_test.CombineFnLifecycleTest ‑ test_non_liftable_combine
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_0_dill ‑ test_combine
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_0_dill ‑ test_combine_deepcopy_fails
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_0_dill ‑ test_combining_value_state
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_0_dill ‑ test_non_liftable_combine
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_1_cloudpickle ‑ test_combine
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_1_cloudpickle ‑ test_combine_deepcopy_fails
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_1_cloudpickle ‑ test_combining_value_state
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_1_cloudpickle ‑ test_non_liftable_combine
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_2_dill ‑ test_combine
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_2_dill ‑ test_combine_deepcopy_fails
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_2_dill ‑ test_combining_value_state
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_2_dill ‑ test_non_liftable_combine
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_3_cloudpickle ‑ test_combine
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_3_cloudpickle ‑ test_combine_deepcopy_fails
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_3_cloudpickle ‑ test_combining_value_state
apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_3_cloudpickle ‑ test_non_liftable_combine
apache_beam.transforms.combiners_test.CombineGloballyTest ‑ test_combine_globally_for_unbounded_source_with_default
apache_beam.transforms.combiners_test.CombineGloballyTest ‑ test_combine_globally_for_unbounded_source_without_defaults
apache_beam.transforms.combiners_test.CombineTest ‑ test_MeanCombineFn_combine
apache_beam.transforms.combiners_test.CombineTest ‑ test_MeanCombineFn_combine_empty
apache_beam.transforms.combiners_test.CombineTest ‑ test_basic_combiners_display_data
apache_beam.transforms.combiners_test.CombineTest ‑ test_builtin_combines
apache_beam.transforms.combiners_test.CombineTest ‑ test_combine_globally_display_data
apache_beam.transforms.combiners_test.CombineTest ‑ test_combine_globally_with_default
apache_beam.transforms.combiners_test.CombineTest ‑ test_combine_globally_with_default_side_input
apache_beam.transforms.combiners_test.CombineTest ‑ test_combine_globally_without_default
apache_beam.transforms.combiners_test.CombineTest ‑ test_combine_per_key_top_display_data
apache_beam.transforms.combiners_test.CombineTest ‑ test_combine_sample_display_data
apache_beam.transforms.combiners_test.CombineTest ‑ test_combining_with_accumulation_mode_and_fanout
apache_beam.transforms.combiners_test.CombineTest ‑ test_combining_with_sliding_windows_and_fanout_raises_error
apache_beam.transforms.combiners_test.CombineTest ‑ test_custormized_counters_in_combine_fn
apache_beam.transforms.combiners_test.CombineTest ‑ test_custormized_counters_in_combine_fn_empty
apache_beam.transforms.combiners_test.CombineTest ‑ test_empty_global_top
apache_beam.transforms.combiners_test.CombineTest ‑ test_empty_tuple_combine_fn
apache_beam.transforms.combiners_test.CombineTest ‑ test_fixed_windows_combine
apache_beam.transforms.combiners_test.CombineTest ‑ test_global_fanout
apache_beam.transforms.combiners_test.CombineTest ‑ test_global_sample
apache_beam.transforms.combiners_test.CombineTest ‑ test_hot_key_fanout
apache_beam.transforms.combiners_test.CombineTest ‑ test_hot_key_fanout_sharded
apache_beam.transforms.combiners_test.CombineTest ‑ test_per_key_sample
apache_beam.transforms.combiners_test.CombineTest ‑ test_sessions_combine
apache_beam.transforms.combiners_test.CombineTest ‑ test_sharded_top
apache_beam.transforms.combiners_test.CombineTest ‑ test_sharded_top_combine_fn
apache_beam.transforms.combiners_test.CombineTest ‑ test_to_list_and_to_dict1
apache_beam.transforms.combiners_test.CombineTest ‑ test_to_list_and_to_dict2
apache_beam.transforms.combiners_test.CombineTest ‑ test_to_set
apache_beam.transforms.combiners_test.CombineTest ‑ test_top
apache_beam.transforms.combiners_test.CombineTest ‑ test_top_key
apache_beam.transforms.combiners_test.CombineTest ‑ test_top_no_compact
apache_beam.transforms.combiners_test.CombineTest ‑ test_top_shorthands
apache_beam.transforms.combiners_test.CombineTest ‑ test_tuple_combine_fn
apache_beam.transforms.combiners_test.CombineTest ‑ test_tuple_combine_fn_batched_merge
apache_beam.transforms.combiners_test.CombineTest ‑ test_tuple_combine_fn_without_defaults
apache_beam.transforms.combiners_test.CombineValuesTest ‑ test_gbk_immediately_followed_by_combine
apache_beam.transforms.combiners_test.LatestCombineFnTest ‑ test_add_input
apache_beam.transforms.combiners_test.LatestCombineFnTest ‑ test_create_accumulator
apache_beam.transforms.combiners_test.LatestCombineFnTest ‑ test_extract_output
apache_beam.transforms.combiners_test.LatestCombineFnTest ‑ test_merge_accumulators
apache_beam.transforms.combiners_test.LatestCombineFnTest ‑ test_with_input_types_decorator_violation
apache_beam.transforms.combiners_test.LatestTest ‑ test_globally
apache_beam.transforms.combiners_test.LatestTest ‑ test_globally_empty
apache_beam.transforms.combiners_test.LatestTest ‑ test_per_key
apache_beam.transforms.combiners_test.LatestTest ‑ test_per_key_empty
apache_beam.transforms.combiners_test.TimestampCombinerTest ‑ test_combiner_earliest
apache_beam.transforms.combiners_test.TimestampCombinerTest ‑ test_combiner_latest
apache_beam.transforms.core_test.CreateTest ‑ test_dofn_with_explicit_return_none
apache_beam.transforms.core_test.CreateTest ‑ test_dofn_with_implicit_return_none_missing_return_and_yield
apache_beam.transforms.core_test.CreateTest ‑ test_dofn_with_implicit_return_none_return_without_value
apache_beam.transforms.core_test.CreateTest ‑ test_dofn_with_yield_and_return
apache_beam.transforms.core_test.ExceptionHandlingTest ‑ test_handles_callbacks
apache_beam.transforms.core_test.ExceptionHandlingTest ‑ test_handles_no_callback_triggered
apache_beam.transforms.core_test.ExceptionHandlingTest ‑ test_routes_failures
apache_beam.transforms.core_test.FlatMapTest ‑ test_default
apache_beam.transforms.core_test.FlattenTest ‑ test_flatten_identical_windows
apache_beam.transforms.core_test.FlattenTest ‑ test_flatten_mismatched_windows
apache_beam.transforms.core_test.FlattenTest ‑ test_flatten_no_windows
apache_beam.transforms.core_test.PartitionTest ‑ test_partition_boundedness
apache_beam.transforms.create_test.CreateTest ‑ test_create_source_dynamic_splitting
apache_beam.transforms.create_test.CreateTest ‑ test_create_source_progress
apache_beam.transforms.create_test.CreateTest ‑ test_create_source_read
apache_beam.transforms.create_test.CreateTest ‑ test_create_source_read_reentrant
apache_beam.transforms.create_test.CreateTest ‑ test_create_source_read_reentrant_with_initial_splits
apache_beam.transforms.create_test.CreateTest ‑ test_create_source_read_with_initial_splits
apache_beam.transforms.create_test.CreateTest ‑ test_create_transform
apache_beam.transforms.create_test.CreateTest ‑ test_create_uses_coder_for_pickling
apache_beam.transforms.dataflow_distribution_counter_test.DataflowDistributionAccumulatorTest ‑ test_add_input
apache_beam.transforms.dataflow_distribution_counter_test.DataflowDistributionAccumulatorTest ‑ test_calculate_bucket_index_with_input_0
apache_beam.transforms.dataflow_distribution_counter_test.DataflowDistributionAccumulatorTest ‑ test_calculate_bucket_index_within_max_long
apache_beam.transforms.dataflow_distribution_counter_test.DataflowDistributionAccumulatorTest ‑ test_translate_to_histogram_with_input_0
apache_beam.transforms.dataflow_distribution_counter_test.DataflowDistributionAccumulatorTest ‑ test_translate_to_histogram_with_max_input
apache_beam.transforms.deduplicate_test.DeduplicateTest ‑ test_deduplication_in_different_windows
apache_beam.transforms.deduplicate_test.DeduplicateTest ‑ test_deduplication_with_event_time
apache_beam.transforms.deduplicate_test.DeduplicateTest ‑ test_deduplication_with_processing_time
apache_beam.transforms.display_test.DisplayDataTest ‑ test_base_cases
apache_beam.transforms.display_test.DisplayDataTest ‑ test_create_list_display_data
apache_beam.transforms.display_test.DisplayDataTest ‑ test_display_data_item_matcher
apache_beam.transforms.display_test.DisplayDataTest ‑ test_drop_if_none
apache_beam.transforms.display_test.DisplayDataTest ‑ test_inheritance_dofn
apache_beam.transforms.display_test.DisplayDataTest ‑ test_inheritance_ptransform
apache_beam.transforms.display_test.DisplayDataTest ‑ test_subcomponent
apache_beam.transforms.display_test.DisplayDataTest ‑ test_unicode_type_display_data
apache_beam.transforms.display_test.DisplayDataTest ‑ test_unsupported_type_display_data
apache_beam.transforms.display_test.DisplayDataTest ‑ test_value_provider_display_data
apache_beam.transforms.dofn_lifecycle_test.DoFnLifecycleTest ‑ test_dofn_lifecycle
apache_beam.transforms.dofn_lifecycle_test.LocalDoFnLifecycleTest ‑ test_dofn_lifecycle
apache_beam.transforms.enrichment_handlers.bigquery_it_test.TestBigQueryEnrichmentIT ‑ test_bigquery_enrichment
apache_beam.transforms.enrichment_handlers.bigquery_it_test.TestBigQueryEnrichmentIT ‑ test_bigquery_enrichment_bad_request
apache_beam.transforms.enrichment_handlers.bigquery_it_test.TestBigQueryEnrichmentIT ‑ test_bigquery_enrichment_batched
apache_beam.transforms.enrichment_handlers.bigquery_it_test.TestBigQueryEnrichmentIT ‑ test_bigquery_enrichment_batched_multiple_fields
apache_beam.transforms.enrichment_handlers.bigquery_it_test.TestBigQueryEnrichmentIT ‑ test_bigquery_enrichment_with_condition_value_fn
apache_beam.transforms.enrichment_handlers.bigquery_it_test.TestBigQueryEnrichmentIT ‑ test_bigquery_enrichment_with_query_fn
apache_beam.transforms.enrichment_handlers.bigquery_it_test.TestBigQueryEnrichmentIT ‑ test_bigquery_enrichment_with_redis
apache_beam.transforms.enrichment_handlers.bigquery_test.TestBigQueryEnrichment ‑ test_valid_params_0_
apache_beam.transforms.enrichment_handlers.bigquery_test.TestBigQueryEnrichment ‑ test_valid_params_1_table
apache_beam.transforms.enrichment_handlers.bigquery_test.TestBigQueryEnrichment ‑ test_valid_params_2_table
apache_beam.transforms.enrichment_handlers.bigquery_test.TestBigQueryEnrichment ‑ test_valid_params_3_table
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_bigtable_enrichment_with_lambda
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_bigtable_enrichment_with_redis
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_enrichment_with_bigtable
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_enrichment_with_bigtable_bad_row_filter
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_enrichment_with_bigtable_exception_level
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_enrichment_with_bigtable_no_enrichment
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_enrichment_with_bigtable_raises_key_error
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_enrichment_with_bigtable_raises_not_found
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_enrichment_with_bigtable_row_filter
apache_beam.transforms.enrichment_handlers.bigtable_it_test.TestBigTableEnrichment ‑ test_enrichment_with_bigtable_with_timestamp
apache_beam.transforms.enrichment_handlers.bigtable_test.TestBigTableEnrichmentHandler ‑ test_bigtable_enrichment_invalid_args_0_product_id
apache_beam.transforms.enrichment_handlers.bigtable_test.TestBigTableEnrichmentHandler ‑ test_bigtable_enrichment_invalid_args_1_
apache_beam.transforms.enrichment_handlers.feast_feature_store_it_test
apache_beam.transforms.enrichment_handlers.feast_feature_store_test
apache_beam.transforms.enrichment_handlers.vertex_ai_feature_store_it_test.TestVertexAIFeatureStoreHandler ‑ test_feature_store_enrichment_with_redis
apache_beam.transforms.enrichment_handlers.vertex_ai_feature_store_it_test.TestVertexAIFeatureStoreHandler ‑ test_vertex_ai_feature_store_bigtable_serving_enrichment
apache_beam.transforms.enrichment_handlers.vertex_ai_feature_store_it_test.TestVertexAIFeatureStoreHandler ‑ test_vertex_ai_feature_store_bigtable_serving_enrichment_bad
apache_beam.transforms.enrichment_handlers.vertex_ai_feature_store_it_test.TestVertexAIFeatureStoreHandler ‑ test_vertex_ai_feature_store_wrong_name
apache_beam.transforms.enrichment_handlers.vertex_ai_feature_store_it_test.TestVertexAIFeatureStoreHandler ‑ test_vertex_ai_legacy_feature_store_enrichment
apache_beam.transforms.enrichment_handlers.vertex_ai_feature_store_it_test.TestVertexAIFeatureStoreHandler ‑ test_vertex_ai_legacy_feature_store_enrichment_bad
apache_beam.transforms.enrichment_handlers.vertex_ai_feature_store_it_test.TestVertexAIFeatureStoreHandler ‑ test_vertex_ai_legacy_feature_store_invalid_featurestore
apache_beam.transforms.enrichment_handlers.vertex_ai_feature_store_test.TestVertexAIFeatureStoreHandlerInit ‑ test_raise_error_duplicate_api_endpoint_legacy_store
apache_beam.transforms.enrichment_handlers.vertex_ai_feature_store_test.TestVertexAIFeatureStoreHandlerInit ‑ test_raise_error_duplicate_api_endpoint_online_store
apache_beam.transforms.enrichment_it_test.TestEnrichment ‑ test_http_enrichment
apache_beam.transforms.enrichment_it_test.TestEnrichment ‑ test_http_enrichment_custom_join
apache_beam.transforms.enrichment_test.TestEnrichmentTransform ‑ test_cross_join
apache_beam.transforms.environments_test.EnvironmentOptionsTest ‑ test_environments_with_same_hints_are_equal
apache_beam.transforms.environments_test.EnvironmentOptionsTest ‑ test_process_variables_empty
apache_beam.transforms.environments_test.EnvironmentOptionsTest ‑ test_process_variables_missing_rvalue
apache_beam.transforms.environments_test.EnvironmentOptionsTest ‑ test_process_variables_set
apache_beam.transforms.environments_test.RunnerApiTest ‑ test_default_capabilities
apache_beam.transforms.environments_test.RunnerApiTest ‑ test_environment_encoding
apache_beam.transforms.environments_test.RunnerApiTest ‑ test_sdk_capabilities
apache_beam.transforms.error_handling_test.ErrorHandlingTest ‑ test_collecting_error_handler
apache_beam.transforms.error_handling_test.ErrorHandlingTest ‑ test_error_handling
apache_beam.transforms.error_handling_test.ErrorHandlingTest ‑ test_error_handling_pardo
apache_beam.transforms.error_handling_test.ErrorHandlingTest ‑ test_error_handling_pardo_with_exception_handling_kwargs
apache_beam.transforms.error_handling_test.ErrorHandlingTest ‑ test_error_on_collecting_error_handler_without_output_retrieval
apache_beam.transforms.error_handling_test.ErrorHandlingTest ‑ test_error_on_unclosed_error_handler
apache_beam.transforms.external_it_test.ExternalTransformIT ‑ test_job_python_from_python_it
apache_beam.transforms.external_test.ExternalAnnotationPayloadTest ‑ test_optional_error
apache_beam.transforms.external_test.ExternalAnnotationPayloadTest ‑ test_typehints_payload_builder
apache_beam.transforms.external_test.ExternalAnnotationPayloadTest ‑ test_typing_payload_builder
apache_beam.transforms.external_test.ExternalDataclassesPayloadTest ‑ test_optional_error
apache_beam.transforms.external_test.ExternalDataclassesPayloadTest ‑ test_typehints_payload_builder
apache_beam.transforms.external_test.ExternalDataclassesPayloadTest ‑ test_typing_payload_builder
apache_beam.transforms.external_test.ExternalImplicitPayloadTest ‑ test_implicit_payload_builder
apache_beam.transforms.external_test.ExternalImplicitPayloadTest ‑ test_implicit_payload_builder_with_bytes
apache_beam.transforms.external_test.ExternalTransformTest ‑ test_external_empty_spec_translation
apache_beam.transforms.external_test.ExternalTransformTest ‑ test_external_transform_finder_leaf
apache_beam.transforms.external_test.ExternalTransformTest ‑ test_external_transform_finder_non_leaf
apache_beam.transforms.external_test.ExternalTransformTest ‑ test_nested
apache_beam.transforms.external_test.ExternalTransformTest ‑ test_no_output_coder
apache_beam.transforms.external_test.ExternalTransformTest ‑ test_output_coder
apache_beam.transforms.external_test.ExternalTransformTest ‑ test_payload
apache_beam.transforms.external_test.ExternalTransformTest ‑ test_pipeline_generation
apache_beam.transforms.external_test.ExternalTransformTest ‑ test_pipeline_generation_with_runner_overrides
apache_beam.transforms.external_test.ExternalTransformTest ‑ test_sanitize_java_traceback
apache_beam.transforms.external_test.ExternalTransformTest ‑ test_unique_name
apache_beam.transforms.external_test.ExternalTuplePayloadTest ‑ test_optional_error
apache_beam.transforms.external_test.ExternalTuplePayloadTest ‑ test_typehints_payload_builder
apache_beam.transforms.external_test.ExternalTuplePayloadTest ‑ test_typing_payload_builder
apache_beam.transforms.external_test.JavaClassLookupPayloadBuilderTest ‑ test_build_payload_with_builder_methods
apache_beam.transforms.external_test.JavaClassLookupPayloadBuilderTest ‑ test_build_payload_with_constructor
apache_beam.transforms.external_test.JavaClassLookupPayloadBuilderTest ‑ test_build_payload_with_constructor_method
apache_beam.transforms.external_test.JavaClassLookupPayloadBuilderTest ‑ test_build_payload_with_constructor_twice_fails
apache_beam.transforms.external_test.JavaClassLookupPayloadBuilderTest ‑ test_implicit_builder_with_constructor
apache_beam.transforms.external_test.JavaClassLookupPayloadBuilderTest ‑ test_implicit_builder_with_constructor_method
apache_beam.transforms.external_test.JavaJarExpansionServiceTest ‑ test_classpath
apache_beam.transforms.external_test.JavaJarExpansionServiceTest ‑ test_classpath_with_glob
apache_beam.transforms.external_test.JavaJarExpansionServiceTest ‑ test_classpath_with_gradle_artifact
apache_beam.transforms.external_test.JavaJarExpansionServiceTest ‑ test_classpath_with_url
apache_beam.transforms.external_test.SchemaAwareExternalTransformTest ‑ test_discover_one_config
apache_beam.transforms.external_test.SchemaAwareExternalTransformTest ‑ test_discover_one_config_fails_with_no_configs_found
apache_beam.transforms.external_test.SchemaAwareExternalTransformTest ‑ test_rearrange_kwargs_based_on_discovery
apache_beam.transforms.external_test.SchemaTransformPayloadBuilderTest ‑ test_build_payload
apache_beam.transforms.external_transform_provider_it_test.AutoGenerationScriptIT ‑ test_check_standard_external_transforms_config_in_sync
apache_beam.transforms.external_transform_provider_it_test.AutoGenerationScriptIT ‑ test_pretty_types
apache_beam.transforms.external_transform_provider_it_test.AutoGenerationScriptIT ‑ test_run_pipeline_with_generated_transform
apache_beam.transforms.external_transform_provider_it_test.AutoGenerationScriptIT ‑ test_script_fails_with_invalid_destinations
apache_beam.transforms.external_transform_provider_it_test.AutoGenerationScriptIT ‑ test_script_workflow
apache_beam.transforms.external_transform_provider_it_test.AutoGenerationScriptIT ‑ test_script_workflow_with_modified_transforms
apache_beam.transforms.external_transform_provider_it_test.AutoGenerationScriptIT ‑ test_script_workflow_with_skipped_transform
apache_beam.transforms.external_transform_provider_it_test.ExternalTransformProviderIT ‑ test_generate_sequence_signature_and_doc
apache_beam.transforms.external_transform_provider_it_test.ExternalTransformProviderIT ‑ test_run_generate_sequence
apache_beam.transforms.external_transform_provider_it_test.NameAndTypeUtilsTest ‑ test_infer_name_from_identifier
apache_beam.transforms.external_transform_provider_it_test.NameAndTypeUtilsTest ‑ test_snake_case_to_upper_camel_case
apache_beam.transforms.fully_qualified_named_transform_test.FullyQualifiedNamedTransformTest ‑ test_as_external_transform
apache_beam.transforms.fully_qualified_named_transform_test.FullyQualifiedNamedTransformTest ‑ test_as_external_transform_no_args
apache_beam.transforms.fully_qualified_named_transform_test.FullyQualifiedNamedTransformTest ‑ test_as_external_transform_no_kwargs
apache_beam.transforms.fully_qualified_named_transform_test.FullyQualifiedNamedTransformTest ‑ test_callable_transform
apache_beam.transforms.fully_qualified_named_transform_test.FullyQualifiedNamedTransformTest ‑ test_constructor_transform
apache_beam.transforms.fully_qualified_named_transform_test.FullyQualifiedNamedTransformTest ‑ test_expand
apache_beam.transforms.fully_qualified_named_transform_test.FullyQualifiedNamedTransformTest ‑ test_glob_filter
apache_beam.transforms.fully_qualified_named_transform_test.FullyQualifiedNamedTransformTest ‑ test_resolve
apache_beam.transforms.fully_qualified_named_transform_test.FullyQualifiedNamedTransformTest ‑ test_resolve_by_path_segment
apache_beam.transforms.fully_qualified_named_transform_test.FullyQualifiedNamedTransformTest ‑ test_static_constructor
apache_beam.transforms.fully_qualified_named_transform_test.FullyQualifiedNamedTransformTest ‑ test_test_transform
apache_beam.transforms.managed_iceberg_it_test.ManagedIcebergIT ‑ test_write_read_pipeline
apache_beam.transforms.periodicsequence_it_test.PeriodicSequenceIT ‑ test_periodicsequence_outputs_valid_watermarks_it
apache_beam.transforms.periodicsequence_test.PeriodicSequenceTest ‑ test_periodicimpulse_default_start
apache_beam.transforms.periodicsequence_test.PeriodicSequenceTest ‑ test_periodicimpulse_windowing_on_si
apache_beam.transforms.periodicsequence_test.PeriodicSequenceTest ‑ test_periodicsequence_output_size
apache_beam.transforms.periodicsequence_test.PeriodicSequenceTest ‑ test_periodicsequence_outputs_valid_sequence
apache_beam.transforms.periodicsequence_test.PeriodicSequenceTest ‑ test_periodicsequence_outputs_valid_sequence_in_past
apache_beam.transforms.ptransform_test.DeadLettersTest_0 ‑ test_error_messages
apache_beam.transforms.ptransform_test.DeadLettersTest_0 ‑ test_filters_exceptions
apache_beam.transforms.ptransform_test.DeadLettersTest_0 ‑ test_increment_counter
apache_beam.transforms.ptransform_test.DeadLettersTest_0 ‑ test_lifecycle
apache_beam.transforms.ptransform_test.DeadLettersTest_0 ‑ test_multiple_outputs
apache_beam.transforms.ptransform_test.DeadLettersTest_0 ‑ test_params
apache_beam.transforms.ptransform_test.DeadLettersTest_0 ‑ test_partial
apache_beam.transforms.ptransform_test.DeadLettersTest_0 ‑ test_side_inputs
apache_beam.transforms.ptransform_test.DeadLettersTest_0 ‑ test_threshold
apache_beam.transforms.ptransform_test.DeadLettersTest_0 ‑ test_timeout
apache_beam.transforms.ptransform_test.DeadLettersTest_0 ‑ test_tuples
apache_beam.transforms.ptransform_test.DeadLettersTest_1 ‑ test_error_messages
apache_beam.transforms.ptransform_test.DeadLettersTest_1 ‑ test_filters_exceptions
apache_beam.transforms.ptransform_test.DeadLettersTest_1 ‑ test_increment_counter
apache_beam.transforms.ptransform_test.DeadLettersTest_1 ‑ test_lifecycle
apache_beam.transforms.ptransform_test.DeadLettersTest_1 ‑ test_multiple_outputs
apache_beam.transforms.ptransform_test.DeadLettersTest_1 ‑ test_params
apache_beam.transforms.ptransform_test.DeadLettersTest_1 ‑ test_partial
apache_beam.transforms.ptransform_test.DeadLettersTest_1 ‑ test_side_inputs
apache_beam.transforms.ptransform_test.DeadLettersTest_1 ‑ test_threshold
apache_beam.transforms.ptransform_test.DeadLettersTest_1 ‑ test_timeout
apache_beam.transforms.ptransform_test.DeadLettersTest_1 ‑ test_tuples
apache_beam.transforms.ptransform_test.PTransformLabelsTest ‑ test_apply_custom_transform_with_label
apache_beam.transforms.ptransform_test.PTransformLabelsTest ‑ test_apply_custom_transform_without_label
apache_beam.transforms.ptransform_test.PTransformLabelsTest ‑ test_apply_ptransform_using_decorator
apache_beam.transforms.ptransform_test.PTransformLabelsTest ‑ test_chained_ptransforms
apache_beam.transforms.ptransform_test.PTransformLabelsTest ‑ test_combine_with_label
apache_beam.transforms.ptransform_test.PTransformLabelsTest ‑ test_combine_without_label
apache_beam.transforms.ptransform_test.PTransformLabelsTest ‑ test_default_labels
apache_beam.transforms.ptransform_test.PTransformLabelsTest ‑ test_label_propogation
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_apply_to_crazy_pvaluish
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_apply_to_list
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_chained_ptransforms
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_combine_per_key_with_callable
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_combine_per_key_with_combine_fn
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_combine_per_key_with_side_input_as_arg
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_combine_with_callable
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_combine_with_combine_fn
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_combine_with_side_input_as_arg
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_distinct
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_do_fn_with_finish
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_do_fn_with_start
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_do_fn_with_start_error
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_do_fn_with_windowing_in_finish_bundle
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_do_requires_do_fn_returning_iterable
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_do_with_callable
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_do_with_do_fn
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_do_with_do_fn_returning_dict_raises_warning
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_do_with_do_fn_returning_string_raises_warning
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_do_with_multiple_outputs_maintains_unique_name
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_do_with_side_input_as_arg
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_do_with_side_input_as_keyword_arg
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_do_with_unconstructed_do_fn
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_filter
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_filter_builtin
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_flatmap_builtin
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_flatten_a_flattened_pcollection
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_flatten_input_type_must_be_iterable
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_flatten_input_type_must_be_iterable_of_pcolls
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_flatten_multiple_pcollections_having_multiple_consumers
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_flatten_no_pcollections
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_flatten_one_single_pcollection
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_flatten_pcollections
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_flatten_pcollections_in_iterable
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_flatten_same_pcollections
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_flatten_with
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_group_by_key
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_group_by_key_allow_non_deterministic_coder
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_group_by_key_allow_unsafe_triggers
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_group_by_key_deterministic_coder
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_group_by_key_fake_deterministic_coder
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_group_by_key_input_must_be_kv_pairs
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_group_by_key_non_deterministic_coder
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_group_by_key_only_input_must_be_kv_pairs
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_group_by_key_reiteration
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_group_by_key_unbounded_global_default_trigger
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_group_by_key_unsafe_trigger
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_impulse
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_keys_and_values
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_kv_swap
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_map_builtin
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_multi_input_ptransform
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_multiple_empty_outputs
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_named_annotations
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_named_tuple
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_par_do_with_multiple_outputs_and_using_return
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_par_do_with_multiple_outputs_and_using_yield
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_partition_followed_by_flatten_and_groupbykey
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_partition_with_callable
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_partition_with_callable_and_side_input
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_partition_with_partition_fn
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_read_metrics
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_resource_hint_application_is_additive
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_str
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_tuple_twice
apache_beam.transforms.ptransform_test.PTransformTest ‑ test_undeclared_outputs
apache_beam.transforms.ptransform_test.PTransformTestDisplayData ‑ test_filter_anonymous_function
apache_beam.transforms.ptransform_test.PTransformTestDisplayData ‑ test_filter_named_function
apache_beam.transforms.ptransform_test.PTransformTestDisplayData ‑ test_flatmap_anonymous_function
apache_beam.transforms.ptransform_test.PTransformTestDisplayData ‑ test_flatmap_named_function
apache_beam.transforms.ptransform_test.PTransformTestDisplayData ‑ test_map_anonymous_function
apache_beam.transforms.ptransform_test.PTransformTestDisplayData ‑ test_map_named_function
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_combine_func_type_hint_does_not_take_iterable_using_decorator
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_combine_insufficient_type_hint_information
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_combine_pipeline_type_check_using_methods
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_combine_pipeline_type_check_violation_using_methods
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_combine_pipeline_type_propagation_using_decorators
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_combine_properly_pipeline_type_checks_using_decorator
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_combine_properly_pipeline_type_checks_without_decorator
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_combine_runtime_type_check_satisfied_using_decorators
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_combine_runtime_type_check_using_methods
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_combine_runtime_type_check_violation_using_decorators
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_combine_runtime_type_check_violation_using_methods
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_count_globally_pipeline_type_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_count_globally_runtime_type_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_count_perelement_pipeline_type_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_count_perelement_pipeline_type_checking_violated
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_count_perelement_runtime_type_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_count_perkey_pipeline_type_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_count_perkey_pipeline_type_checking_violated
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_count_perkey_runtime_type_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_disable_pipeline_type_check
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_do_fn_pipeline_pipeline_type_check_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_do_fn_pipeline_pipeline_type_check_violated
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_do_fn_pipeline_runtime_type_check_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_do_fn_pipeline_runtime_type_check_violated
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_eager_execution
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_eager_execution_tagged_outputs
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_filter_does_not_type_check_using_type_hints_decorator
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_filter_does_not_type_check_using_type_hints_method
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_filter_type_checks_using_type_hints_decorator
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_filter_type_checks_using_type_hints_method
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_gbk_type_inference
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_group_by_does_not_type_check
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_group_by_key_only_does_not_type_check
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_group_by_key_only_output_type_deduction
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_group_by_key_output_type_deduction
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_inferred_bad_kv_type
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_map_does_not_type_check_using_type_hints_decorator
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_map_does_not_type_check_using_type_hints_methods
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_map_properly_type_checks_using_type_hints_decorator
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_map_properly_type_checks_using_type_hints_methods
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_mean_globally_pipeline_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_mean_globally_pipeline_checking_violated
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_mean_globally_runtime_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_mean_globally_runtime_checking_violated
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_mean_per_key_pipeline_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_mean_per_key_pipeline_checking_violated
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_mean_per_key_runtime_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_mean_per_key_runtime_checking_violated
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pardo_does_not_type_check_using_type_hint_decorators
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pardo_does_not_type_check_using_type_hint_methods
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pardo_like_inheriting_output_types_from_annotation
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pardo_properly_type_checks_using_type_hint_decorators
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pardo_properly_type_checks_using_type_hint_methods
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pardo_type_inference
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_per_key_pipeline_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_per_key_pipeline_checking_violated
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_per_key_runtime_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pipeline_checking_gbk_insufficient_type_information
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pipeline_checking_pardo_insufficient_type_information
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pipeline_checking_satisfied_but_run_time_types_violate
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pipeline_checking_satisfied_run_time_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pipeline_inference
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pipeline_runtime_checking_violation_composite_type_input
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pipeline_runtime_checking_violation_composite_type_output
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pipeline_runtime_checking_violation_simple_type_input
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pipeline_runtime_checking_violation_simple_type_output
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pipeline_runtime_checking_violation_with_side_inputs_decorator
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_pipeline_runtime_checking_violation_with_side_inputs_via_method
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_run_time_type_checking_enabled_type_violation
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_run_time_type_checking_enabled_types_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_runtime_type_check_python_type_error
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_sample_globally_pipeline_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_sample_globally_runtime_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_sample_per_key_pipeline_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_sample_per_key_runtime_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_to_dict_pipeline_check_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_to_dict_pipeline_check_violated
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_to_dict_runtime_check_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_to_list_pipeline_check_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_to_list_runtime_check_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_top_of_pipeline_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_top_of_runtime_checking_satisfied
apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase ‑ test_type_inference_command_line_flag_toggle
apache_beam.transforms.ptransform_test.SelectTest ‑ test_simple
apache_beam.transforms.ptransform_test.SelectTest ‑ test_type_inference
apache_beam.transforms.ptransform_test.TestGroupBy ‑ test_aggregate
apache_beam.transforms.ptransform_test.TestGroupBy ‑ test_fields
apache_beam.transforms.ptransform_test.TestGroupBy ‑ test_lambdas
apache_beam.transforms.ptransform_test.TestGroupBy ‑ test_pickled_field
apache_beam.transforms.ptransform_test.TestPTransformFn ‑ test_type_checking_fail
apache_beam.transforms.ptransform_test.TestPTransformFn ‑ test_type_checking_success
apache_beam.transforms.ptransform_test.TestPTransformFn ‑ test_type_hints_arg
apache_beam.transforms.resources_test.ResourcesTest ‑ test_known_resource_hints_0
apache_beam.transforms.resources_test.ResourcesTest ‑ test_known_resource_hints_1
apache_beam.transforms.resources_test.ResourcesTest ‑ test_known_resource_hints_2
apache_beam.transforms.resources_test.ResourcesTest ‑ test_known_resource_hints_3
apache_beam.transforms.resources_test.ResourcesTest ‑ test_known_resource_hints_4
apache_beam.transforms.resources_test.ResourcesTest ‑ test_resource_hint_parsing_fails_early_0
apache_beam.transforms.resources_test.ResourcesTest ‑ test_resource_hint_parsing_fails_early_1
apache_beam.transforms.resources_test.ResourcesTest ‑ test_resource_hint_parsing_fails_early_2
apache_beam.transforms.resources_test.ResourcesTest ‑ test_resource_hint_parsing_fails_early_3
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_as_dict_twice
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_as_list_and_as_dict_side_inputs
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_as_list_twice
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_as_singleton_with_different_defaults
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_as_singleton_without_unique_labels
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_default_value_singleton_side_input
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_different_fixed_windows
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_empty_singleton_side_input
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_fixed_global_window
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_flattened_side_input
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_global_global_windows
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_iterable_side_input
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_multi_triggered_gbk_side_input
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_multi_valued_singleton_side_input
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_reiterable_side_input
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_same_fixed_windows
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_sliding_windows
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_windowed_dict
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_windowed_iter
apache_beam.transforms.sideinputs_test.SideInputsTest ‑ test_windowed_singleton
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_agg
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_filter
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_generate_data
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_map
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_project
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_row
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_tagged_join
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_windowing_before_sql
apache_beam.transforms.sql_test.SqlTransformTest ‑ test_zetasql_generate_data
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_00
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_01
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_02
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_03
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_04
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_05
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_06
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_07
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_08
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_09
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_10
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_11
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_12
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_13
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_14
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_15
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_16
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_17
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_18
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_19
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_20
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_21
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_22
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_23
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_correctness_24
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_00
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_01
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_02
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_03
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_04
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_05
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_06
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_07
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_08
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_09
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_10
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_11
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_12
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_13
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_14
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_15
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_16
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_17
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_18
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_19
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_20
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_21
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_22
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_23
apache_beam.transforms.stats_test.ApproximateQuantilesBufferTest ‑ test_efficiency_24
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_alternate_quantiles
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_batched_quantiles
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_batched_weighted_quantiles
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_duplicates
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_global_display_data
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_large_quantiles
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_log_distribution
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_lots_of_duplicates
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_perkey_display_data
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_quantiles_globally_weighted
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_quantiles_globaly
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_quantiles_merge_accumulators
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_quantiles_per_key
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_quantiles_per_key_weighted
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_quantiles_per_key_with_key_argument
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_random_quantiles
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_singleton
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_uneven_quantiles
apache_beam.transforms.stats_test.ApproximateQuantilesTest ‑ test_zipfian_distribution
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_combine_fn_requires_compatible_coder
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_combine_fn_requires_nondeterministic_coder
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_global_0_small_population_by_size
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_global_1_large_population_by_size
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_global_2_with_duplicates_by_size
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_global_3_small_population_by_error
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_global_4_large_population_by_error
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_global_value_error_0_invalid_input_size
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_global_value_error_1_invalid_type_size
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_global_value_error_2_invalid_small_error
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_global_value_error_3_invalid_big_error
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_global_value_error_4_no_input
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_global_value_error_5_both_input
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_perkey_0_by_size
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_approximate_unique_perkey_1_by_error
apache_beam.transforms.stats_test.ApproximateUniqueTest_0 ‑ test_get_sample_size_from_est_error
apache_beam.transforms.timestamped_value_type_test.TypeCheckTimestampedValueTestCase ‑ test_opts_with_check
apache_beam.transforms.timestamped_value_type_test.TypeCheckTimestampedValueTestCase ‑ test_opts_with_check_list_str
apache_beam.transforms.timestamped_value_type_test.TypeCheckTimestampedValueTestCase ‑ test_opts_with_check_typevar
apache_beam.transforms.timestamped_value_type_test.TypeCheckTimestampedValueTestCase ‑ test_opts_with_check_wrong_data
apache_beam.transforms.timestamped_value_type_test.TypeCheckTimestampedValueTestCase ‑ test_opts_with_check_wrong_data_list_str
apache_beam.transforms.timestamped_value_type_test.TypeCheckTimestampedValueTestCase ‑ test_pcoll_default_hints
apache_beam.transforms.timestamped_value_type_test.TypeCheckTimestampedValueTestCase ‑ test_pcoll_with_output_hints
apache_beam.transforms.transforms_keyword_only_args_test.KeywordOnlyArgsTests ‑ test_combine_keyword_only_args
apache_beam.transforms.transforms_keyword_only_args_test.KeywordOnlyArgsTests ‑ test_do_fn_keyword_only_args
apache_beam.transforms.transforms_keyword_only_args_test.KeywordOnlyArgsTests ‑ test_side_input_keyword_only_args
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_bad_expected_values
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_bad_expected_window
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_bad_output
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_discarding_early_fixed
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_early_late_sessions
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_fixed_default
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_fixed_default_late_data
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_fixed_drop_late_data_after_allowed_lateness
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_garbage_collection
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_known_late_data_no_watermark_hold_possible
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_known_late_data_watermark
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_missing_output
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_missing_output_at_end
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_earliest
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_earliest_1
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_eow
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_timestamp_combiner_earliest
apache_beam.transforms.trigger_test.BatchTranscriptTest ‑ test_timestamp_combiner_latest
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_afer_all_all_may_finish
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_after_all_some_may_finish
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_after_any_all_safe
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_after_any_one_may_finish
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_after_count
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_after_each_all_may_finish
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_after_each_at_least_one_safe
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_after_processing
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_after_watermark_allowed_lateness_safe_late
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_after_watermark_no_allowed_lateness
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_after_watermark_no_allowed_lateness_safe_late
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_after_watermark_no_late_trigger
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_always
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_default_trigger
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_never
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_repeatedly_safe_underlying
apache_beam.transforms.trigger_test.MayLoseDataTest ‑ test_repeatedly_unsafe_underlying
apache_beam.transforms.trigger_test.RunnerApiTest ‑ test_trigger_encoding
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_bad_expected_values
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_bad_expected_window
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_bad_output
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_discarding_early_fixed
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_early_late_sessions
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_fixed_default
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_fixed_default_late_data
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_fixed_drop_late_data_after_allowed_lateness
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_garbage_collection
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_known_late_data_no_watermark_hold_possible
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_known_late_data_watermark
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_missing_output

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

873 tests found (test 644 to 873) 

There are 873 tests, see "Raw output" for the list of tests 644 to 873.
Raw output 
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_missing_output_at_end
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_earliest
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_earliest_1
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_eow
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_timestamp_combiner_earliest
apache_beam.transforms.trigger_test.TestStreamTranscriptTest ‑ test_timestamp_combiner_latest
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_bad_expected_values
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_bad_expected_window
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_bad_output
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_discarding_early_fixed
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_early_late_sessions
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_fixed_default
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_fixed_default_late_data
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_fixed_drop_late_data_after_allowed_lateness
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_garbage_collection
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_known_late_data_no_watermark_hold_possible
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_known_late_data_watermark
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_missing_output
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_missing_output_at_end
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_earliest
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_earliest_1
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_eow
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_timestamp_combiner_earliest
apache_beam.transforms.trigger_test.TriggerDriverTranscriptTest ‑ test_timestamp_combiner_latest
apache_beam.transforms.trigger_test.TriggerPipelineTest ‑ test_after_count
apache_beam.transforms.trigger_test.TriggerPipelineTest ‑ test_after_count_streaming
apache_beam.transforms.trigger_test.TriggerPipelineTest ‑ test_after_processing_time
apache_beam.transforms.trigger_test.TriggerPipelineTest ‑ test_always
apache_beam.transforms.trigger_test.TriggerPipelineTest ‑ test_multiple_accumulating_firings
apache_beam.transforms.trigger_test.TriggerPipelineTest ‑ test_never
apache_beam.transforms.trigger_test.TriggerPipelineTest ‑ test_on_pane_watermark_hold_no_pipeline_stall
apache_beam.transforms.trigger_test.TriggerPipelineTest ‑ test_repeatedly_after_processing_time
apache_beam.transforms.trigger_test.TriggerTest ‑ test_fixed_after_count
apache_beam.transforms.trigger_test.TriggerTest ‑ test_fixed_after_first
apache_beam.transforms.trigger_test.TriggerTest ‑ test_fixed_watermark
apache_beam.transforms.trigger_test.TriggerTest ‑ test_fixed_watermark_with_early
apache_beam.transforms.trigger_test.TriggerTest ‑ test_fixed_watermark_with_early_late
apache_beam.transforms.trigger_test.TriggerTest ‑ test_picklable_output
apache_beam.transforms.trigger_test.TriggerTest ‑ test_repeatedly_after_first
apache_beam.transforms.trigger_test.TriggerTest ‑ test_sessions_after_all
apache_beam.transforms.trigger_test.TriggerTest ‑ test_sessions_after_count
apache_beam.transforms.trigger_test.TriggerTest ‑ test_sessions_after_each
apache_beam.transforms.trigger_test.TriggerTest ‑ test_sessions_default
apache_beam.transforms.trigger_test.TriggerTest ‑ test_sessions_repeatedly_after_count
apache_beam.transforms.trigger_test.TriggerTest ‑ test_sessions_watermark
apache_beam.transforms.trigger_test.TriggerTest ‑ test_sessions_watermark_with_early_late
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_bad_expected_values
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_bad_expected_window
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_bad_output
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_discarding_early_fixed
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_early_late_sessions
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_fixed_default
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_fixed_default_late_data
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_fixed_drop_late_data_after_allowed_lateness
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_garbage_collection
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_known_late_data_no_watermark_hold_possible
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_known_late_data_watermark
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_missing_output
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_missing_output_at_end
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_earliest
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_earliest_1
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_timestamp_combiner_custom_timestamping_eow
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_timestamp_combiner_earliest
apache_beam.transforms.trigger_test.WeakTestStreamTranscriptTest ‑ test_timestamp_combiner_latest
apache_beam.transforms.userstate_test.InterfaceTest ‑ test_bad_signatures
apache_beam.transforms.userstate_test.InterfaceTest ‑ test_good_signatures
apache_beam.transforms.userstate_test.InterfaceTest ‑ test_param_construction
apache_beam.transforms.userstate_test.InterfaceTest ‑ test_spec_construction
apache_beam.transforms.userstate_test.InterfaceTest ‑ test_state_spec_proto_conversion
apache_beam.transforms.userstate_test.InterfaceTest ‑ test_stateful_dofn_detection
apache_beam.transforms.userstate_test.InterfaceTest ‑ test_validate_dofn
apache_beam.transforms.userstate_test.InterfaceTest ‑ test_validation_typos
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_clearing_bag_state
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_clearing_read_modify_write_state
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_clearing_set_state
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_dynamic_timer_and_simple_timer
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_dynamic_timer_clear_then_set_timer
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_dynamic_timer_clear_timer
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_dynamic_timer_multiple
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_dynamic_timer_simple_dofn
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_generate_sequence_with_realtime_timer
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_hash_join
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_index_assignment
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_simple_read_modify_write_stateful_dofn
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_simple_set_stateful_dofn
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_simple_stateful_dofn
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_simple_stateful_dofn_combining
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_stateful_dofn_nonkeyed_input
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_stateful_set_state_clean_portably
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_stateful_set_state_portably
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_timer_default_tag
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_timer_output_timestamp
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_timer_output_timestamp_and_window
apache_beam.transforms.userstate_test.StatefulDoFnOnDirectRunnerTest ‑ test_two_timers_one_function
apache_beam.transforms.util_test.BatchElementsTest ‑ test_constant_batch
apache_beam.transforms.util_test.BatchElementsTest ‑ test_constant_batch_no_metrics
apache_beam.transforms.util_test.BatchElementsTest ‑ test_global_batch_timestamps
apache_beam.transforms.util_test.BatchElementsTest ‑ test_grows_to_max_batch
apache_beam.transforms.util_test.BatchElementsTest ‑ test_ignore_first_n_batch_size
apache_beam.transforms.util_test.BatchElementsTest ‑ test_ignore_next_timing
apache_beam.transforms.util_test.BatchElementsTest ‑ test_no_numpy_regression
apache_beam.transforms.util_test.BatchElementsTest ‑ test_numpy_regression
apache_beam.transforms.util_test.BatchElementsTest ‑ test_sized_batches
apache_beam.transforms.util_test.BatchElementsTest ‑ test_sized_windowed_batches
apache_beam.transforms.util_test.BatchElementsTest ‑ test_stateful_buffering_timer_in_fixed_window_streaming
apache_beam.transforms.util_test.BatchElementsTest ‑ test_stateful_buffering_timer_in_global_window_streaming
apache_beam.transforms.util_test.BatchElementsTest ‑ test_stateful_constant_batch
apache_beam.transforms.util_test.BatchElementsTest ‑ test_stateful_grows_to_max_batch
apache_beam.transforms.util_test.BatchElementsTest ‑ test_stateful_in_global_window
apache_beam.transforms.util_test.BatchElementsTest ‑ test_target_duration
apache_beam.transforms.util_test.BatchElementsTest ‑ test_target_duration_including_fixed_cost
apache_beam.transforms.util_test.BatchElementsTest ‑ test_target_overhead
apache_beam.transforms.util_test.BatchElementsTest ‑ test_variance
apache_beam.transforms.util_test.BatchElementsTest ‑ test_windowed_batches
apache_beam.transforms.util_test.CoGroupByKeyTest ‑ test_co_group_by_key_on_dict
apache_beam.transforms.util_test.CoGroupByKeyTest ‑ test_co_group_by_key_on_dict_with_tuple_keys
apache_beam.transforms.util_test.CoGroupByKeyTest ‑ test_co_group_by_key_on_empty
apache_beam.transforms.util_test.CoGroupByKeyTest ‑ test_co_group_by_key_on_iterable
apache_beam.transforms.util_test.CoGroupByKeyTest ‑ test_co_group_by_key_on_list
apache_beam.transforms.util_test.CoGroupByKeyTest ‑ test_co_group_by_key_on_one
apache_beam.transforms.util_test.CoGroupByKeyTest ‑ test_co_group_by_key_on_tuple
apache_beam.transforms.util_test.GroupIntoBatchesTest ‑ test_buffering_timer_in_fixed_window_streaming
apache_beam.transforms.util_test.GroupIntoBatchesTest ‑ test_buffering_timer_in_global_window_streaming
apache_beam.transforms.util_test.GroupIntoBatchesTest ‑ test_in_global_window
apache_beam.transforms.util_test.GroupIntoBatchesTest ‑ test_in_global_window_with_synthetic_source
apache_beam.transforms.util_test.GroupIntoBatchesTest ‑ test_output_typehints
apache_beam.transforms.util_test.GroupIntoBatchesTest ‑ test_runner_api
apache_beam.transforms.util_test.GroupIntoBatchesTest ‑ test_runtime_type_check
apache_beam.transforms.util_test.GroupIntoBatchesTest ‑ test_with_sharded_key_in_global_window
apache_beam.transforms.util_test.IdentityWindowTest ‑ test_no_window_context_fails
apache_beam.transforms.util_test.IdentityWindowTest ‑ test_window_preserved
apache_beam.transforms.util_test.LogElementsTest ‑ test_ptransform_output
apache_beam.transforms.util_test.LogElementsTest ‑ test_setting_level_uses_appropriate_log_channel
apache_beam.transforms.util_test.LogElementsTest ‑ test_stdout_logs
apache_beam.transforms.util_test.RegexTest ‑ test_all_matched
apache_beam.transforms.util_test.RegexTest ‑ test_all_matched_pattern
apache_beam.transforms.util_test.RegexTest ‑ test_find
apache_beam.transforms.util_test.RegexTest ‑ test_find_all_groups
apache_beam.transforms.util_test.RegexTest ‑ test_find_empty
apache_beam.transforms.util_test.RegexTest ‑ test_find_group
apache_beam.transforms.util_test.RegexTest ‑ test_find_group_name
apache_beam.transforms.util_test.RegexTest ‑ test_find_group_name_pattern
apache_beam.transforms.util_test.RegexTest ‑ test_find_kv
apache_beam.transforms.util_test.RegexTest ‑ test_find_kv_none
apache_beam.transforms.util_test.RegexTest ‑ test_find_kv_pattern
apache_beam.transforms.util_test.RegexTest ‑ test_find_pattern
apache_beam.transforms.util_test.RegexTest ‑ test_match
apache_beam.transforms.util_test.RegexTest ‑ test_match_entire_line
apache_beam.transforms.util_test.RegexTest ‑ test_match_group
apache_beam.transforms.util_test.RegexTest ‑ test_match_group_empty
apache_beam.transforms.util_test.RegexTest ‑ test_match_group_kv
apache_beam.transforms.util_test.RegexTest ‑ test_match_group_kv_none
apache_beam.transforms.util_test.RegexTest ‑ test_match_group_kv_pattern
apache_beam.transforms.util_test.RegexTest ‑ test_match_group_name
apache_beam.transforms.util_test.RegexTest ‑ test_match_group_name_pattern
apache_beam.transforms.util_test.RegexTest ‑ test_match_kv_group_name_none
apache_beam.transforms.util_test.RegexTest ‑ test_match_kv_group_names
apache_beam.transforms.util_test.RegexTest ‑ test_match_kv_group_names_pattern
apache_beam.transforms.util_test.RegexTest ‑ test_match_none
apache_beam.transforms.util_test.RegexTest ‑ test_match_pattern
apache_beam.transforms.util_test.RegexTest ‑ test_replace_all
apache_beam.transforms.util_test.RegexTest ‑ test_replace_all_mixed
apache_beam.transforms.util_test.RegexTest ‑ test_replace_all_mixed_pattern
apache_beam.transforms.util_test.RegexTest ‑ test_replace_first
apache_beam.transforms.util_test.RegexTest ‑ test_replace_first_mixed
apache_beam.transforms.util_test.RegexTest ‑ test_replace_first_mixed_pattern
apache_beam.transforms.util_test.RegexTest ‑ test_split
apache_beam.transforms.util_test.RegexTest ‑ test_split_pattern
apache_beam.transforms.util_test.RegexTest ‑ test_split_with_empty
apache_beam.transforms.util_test.RegexTest ‑ test_split_without_empty
apache_beam.transforms.util_test.ReifyTest ‑ test_timestamp
apache_beam.transforms.util_test.ReifyTest ‑ test_timestamp_in_value
apache_beam.transforms.util_test.ReifyTest ‑ test_window
apache_beam.transforms.util_test.ReifyTest ‑ test_window_in_value
apache_beam.transforms.util_test.ReshuffleTest ‑ test_reshuffle_after_gbk_contents_unchanged
apache_beam.transforms.util_test.ReshuffleTest ‑ test_reshuffle_contents_unchanged
apache_beam.transforms.util_test.ReshuffleTest ‑ test_reshuffle_contents_unchanged_with_buckets
apache_beam.transforms.util_test.ReshuffleTest ‑ test_reshuffle_contents_unchanged_with_wrong_buckets
apache_beam.transforms.util_test.ReshuffleTest ‑ test_reshuffle_global_window
apache_beam.transforms.util_test.ReshuffleTest ‑ test_reshuffle_preserves_timestamps
apache_beam.transforms.util_test.ReshuffleTest ‑ test_reshuffle_sliding_window
apache_beam.transforms.util_test.ReshuffleTest ‑ test_reshuffle_streaming_global_window
apache_beam.transforms.util_test.ReshuffleTest ‑ test_reshuffle_streaming_global_window_with_buckets
apache_beam.transforms.util_test.ReshuffleTest ‑ test_reshuffle_timestamps_unchanged
apache_beam.transforms.util_test.ReshuffleTest ‑ test_reshuffle_unpicklable_in_global_window
apache_beam.transforms.util_test.ReshuffleTest ‑ test_reshuffle_unpicklable_in_non_global_window
apache_beam.transforms.util_test.ReshuffleTest ‑ test_reshuffle_window_fn_preserved
apache_beam.transforms.util_test.ReshuffleTest ‑ test_reshuffle_windows_unchanged
apache_beam.transforms.util_test.TeeTest ‑ test_tee
apache_beam.transforms.util_test.ToStringTest ‑ test_tostring_elements
apache_beam.transforms.util_test.ToStringTest ‑ test_tostring_iterables
apache_beam.transforms.util_test.ToStringTest ‑ test_tostring_iterables_with_delimeter
apache_beam.transforms.util_test.ToStringTest ‑ test_tostring_kvs
apache_beam.transforms.util_test.ToStringTest ‑ test_tostring_kvs_delimeter
apache_beam.transforms.util_test.ToStringTest ‑ test_tostring_kvs_empty_delimeter
apache_beam.transforms.util_test.WaitOnTest ‑ test_find
apache_beam.transforms.util_test.WithKeysTest ‑ test_args_kwargs_k
apache_beam.transforms.util_test.WithKeysTest ‑ test_callable_k
apache_beam.transforms.util_test.WithKeysTest ‑ test_constant_k
apache_beam.transforms.util_test.WithKeysTest ‑ test_sideinputs
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_cogroup_by_key
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_combine_globally
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_combine_per_key
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_flatten
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_group_by_key
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_multi_input_output_with_sideinput
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_partition
apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest ‑ test_prefix
apache_beam.transforms.window_test.RunnerApiTest ‑ test_windowfn_encoding
apache_beam.transforms.window_test.RunnerApiTest ‑ test_windowing_encoding
apache_beam.transforms.window_test.WindowTest ‑ test_custom_windows
apache_beam.transforms.window_test.WindowTest ‑ test_fixed_windows
apache_beam.transforms.window_test.WindowTest ‑ test_global_window
apache_beam.transforms.window_test.WindowTest ‑ test_rewindow
apache_beam.transforms.window_test.WindowTest ‑ test_rewindow_regroup
apache_beam.transforms.window_test.WindowTest ‑ test_sessions
apache_beam.transforms.window_test.WindowTest ‑ test_sessions_merging
apache_beam.transforms.window_test.WindowTest ‑ test_sliding_windows
apache_beam.transforms.window_test.WindowTest ‑ test_sliding_windows_assignment
apache_beam.transforms.window_test.WindowTest ‑ test_sliding_windows_assignment_fraction
apache_beam.transforms.window_test.WindowTest ‑ test_sliding_windows_assignment_fraction_large_offset
apache_beam.transforms.window_test.WindowTest ‑ test_timestamped_value
apache_beam.transforms.window_test.WindowTest ‑ test_timestamped_value_cmp
apache_beam.transforms.window_test.WindowTest ‑ test_timestamped_with_combiners
apache_beam.transforms.window_test.WindowTest ‑ test_window_assignment_idempotency
apache_beam.transforms.window_test.WindowTest ‑ test_window_assignment_through_multiple_gbk_idempotency
apache_beam.transforms.write_ptransform_test.WriteTest ‑ test_write
apache_beam.transforms.write_ptransform_test.WriteTest ‑ test_write_no_init_result
apache_beam.transforms.write_ptransform_test.WriteTest ‑ test_write_no_write_results
apache_beam.transforms.write_ptransform_test.WriteTest ‑ test_write_with_empty_pcollection
View more details on GitHub Actions