diff --git a/sdks/python/apache_beam/pipeline.py b/sdks/python/apache_beam/pipeline.py index c57f74c51f72..caed03943e19 100644 --- a/sdks/python/apache_beam/pipeline.py +++ b/sdks/python/apache_beam/pipeline.py @@ -1230,7 +1230,9 @@ def __init__( self.full_label = full_label self.main_inputs = dict(main_inputs or {}) - self.side_inputs = tuple() if transform is None else transform.side_inputs + self.side_inputs = ( + tuple() if transform is None else getattr( + transform, 'side_inputs', tuple())) self.outputs = {} # type: Dict[Union[str, int, None], pvalue.PValue] self.parts = [] # type: List[AppliedPTransform] self.environment_id = environment_id if environment_id else None # type: Optional[str]