Apache Beam Python