diff --git a/sdks/python/apache_beam/yaml/yaml_transform.py b/sdks/python/apache_beam/yaml/yaml_transform.py index 327023742bc6..3837f28ed4e9 100644 --- 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', {}) + }, '__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', {}) + }, '__line__': spec['__line__'], '__uuid__': spec['__uuid__'], }