docs: def get_pe(self):
          """Get the Streams processing element this operator is executing in.
  
          Returns:
              PE: Processing element for this operator.
  
          .. versionadded:: 1.9
          """
          return PE(self.rest_client.make_request(self.pe), self.rest_client)