[beam] branch master updated: Fix SDF typo. (#25765)

[riteshghorse]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new ec2138ba89e Fix SDF typo. (#25765)
ec2138ba89e is described below

commit ec2138ba89e79b87c9b04a5d7ecb32d1071aa3a1
Author: Robert Bradshaw <rober...@gmail.com>
AuthorDate: Wed Mar 8 11:37:44 2023 -0800

    Fix SDF typo. (#25765)
---
 .../runners/portability/fn_api_runner/fn_runner_test.py      | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

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 487b1e9619d..ed09bb8f223 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
@@ -987,7 +987,7 @@ class FnApiRunnerTest(unittest.TestCase):
     self.run_sdf_initiated_checkpointing(is_drain=True)
 
   def test_sdf_default_truncate_when_bounded(self):
-    class SimleSDF(beam.DoFn):
+    class SimpleSDF(beam.DoFn):
       def process(
           self,
           element,
@@ -1000,11 +1000,11 @@ class FnApiRunnerTest(unittest.TestCase):
           cur += 1
 
     with self.create_pipeline(is_drain=True) as p:
-      actual = (p | beam.Create([10]) | beam.ParDo(SimleSDF()))
+      actual = (p | beam.Create([10]) | beam.ParDo(SimpleSDF()))
       assert_that(actual, equal_to(range(10)))
 
   def test_sdf_default_truncate_when_unbounded(self):
-    class SimleSDF(beam.DoFn):
+    class SimpleSDF(beam.DoFn):
       def process(
           self,
           element,
@@ -1017,11 +1017,11 @@ class FnApiRunnerTest(unittest.TestCase):
           cur += 1
 
     with self.create_pipeline(is_drain=True) as p:
-      actual = (p | beam.Create([10]) | beam.ParDo(SimleSDF()))
+      actual = (p | beam.Create([10]) | beam.ParDo(SimpleSDF()))
       assert_that(actual, equal_to([]))
 
   def test_sdf_with_truncate(self):
-    class SimleSDF(beam.DoFn):
+    class SimpleSDF(beam.DoFn):
       def process(
           self,
           element,
@@ -1034,7 +1034,7 @@ class FnApiRunnerTest(unittest.TestCase):
           cur += 1
 
     with self.create_pipeline(is_drain=True) as p:
-      actual = (p | beam.Create([10]) | beam.ParDo(SimleSDF()))
+      actual = (p | beam.Create([10]) | beam.ParDo(SimpleSDF()))
       assert_that(actual, equal_to(range(5)))
 
   def test_group_by_key(self):