@staticmethod
  def Search(query, unused_request):
    if users.is_current_user_admin():
      return query  # All Pipelines.
    return Pipeline.query(ancestor=user.User.GetUserKey())
Search for pipelines owned by this user (admins see all pipelines).
dataset/ETHPy150Open GoogleCloudPlatform/Data-Pipeline/app/src/model/pipeline.py/Pipeline.Search