[beam] branch direct_runner_bug updated: Add test

[an...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

anandinguva pushed a commit to branch direct_runner_bug
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/direct_runner_bug by this push:
     new 60e7ed144be Add test
60e7ed144be is described below

commit 60e7ed144be5d80974af76b9b0dcd1594e0f1365
Author: Anand Inguva <an...@gmail.com>
AuthorDate: Tue Jul 11 12:28:00 2023 -0400

    Add test
---
 .../runners/portability/fn_api_runner/fn_runner_test.py          | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py b/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py
index ed09bb8f223..b55c7162aea 100644
--- a/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py
+++ b/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py
@@ -1831,6 +1831,15 @@ class FnApiRunnerTestWithGrpcAndMultiWorkers(FnApiRunnerTest):
     p._options.view_as(DebugOptions).experiments.remove('beam_fn_api')
     return p
 
+  def test_group_by_key_with_empty_pcoll_elements(self):
+    with self.create_pipeline() as p:
+      res = (
+          p
+          | beam.Create([('test_key', 'test_value')])
+          | beam.Filter(lambda x: False)
+          | beam.GroupByKey())
+      assert_that(res, equal_to([]))
+
   def test_metrics(self):
     raise unittest.SkipTest("This test is for a single worker only.")