[yaml] propogate error_handling to windowing composite config

Signed-off-by: Jeffrey Kinard <[email protected]>
apache · Dec 23, 2024 · 71bf559 · 71bf559
1 parent 7c86bf3
commit 71bf559
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/sdks/python/apache_beam/yaml/yaml_transform.py b/sdks/python/apache_beam/yaml/yaml_transform.py
@@ -771,6 +771,9 @@ def preprocess_windowing(spec):
         'transforms': [modified_spec] + windowing_transforms,
         'input': spec['input'],
         'output': modified_spec['__uuid__'],
+        'config': {
+            'error_handling': spec.get('config').get('error_handling', None)
+        } or {},
         '__line__': spec['__line__'],
         '__uuid__': spec['__uuid__'],
     }
@@ -805,6 +808,9 @@ def preprocess_windowing(spec):
         'name': spec.get('name', None) or spec['type'],
         'transforms': [modified_spec] + windowing_transforms,
         'output': windowed_outputs,
+        'config': {
+            'error_handling': spec.get('config').get('error_handling', None)
+        } or {},
         '__line__': spec['__line__'],
         '__uuid__': spec['__uuid__'],
     }