def __call__(self, env, start_response):


    remote_addr = (env.get(X_GOOGLE_REAL_IP_ENV_KEY, '') or
                   env.get(WSGI_REMOTE_ADDR_ENV_KEY, ''))
    path = env['PATH_INFO']
    if path == '/_ah/stop':


      return self.ServeApp(internal_app, 'internal', env, start_response)

    if path == '/_ah/health':
      if not self._CheckIsValidHealthCheckAddress(remote_addr):
        logging.error('Invalid health check address %s, aborting request!',
                      remote_addr)
        start_response('403 Forbidden', [])
        return ['<h1>403 Forbidden</h1>\n']
      return self.ServeHealthCheck(env, start_response, remote_addr)
    for (url, script, l7_safe, appinfo_external) in self.handlers:
      matcher = re.match(url, path)
      if matcher and matcher.end() == len(path):




        if l7_safe or self._CheckIsTrustedIpAddress(remote_addr):


          if script:
            return self.GetUserAppAndServe(script, env, start_response)
          else:
            return self.ServeStaticFile(
                matcher, appinfo_external, env, start_response)
        else:




          redirect_url = '%s%s' % (self.l7_unsafe_redirect_url, path)
          logging.info('Returning 307 to %s for request from %s.',
                       redirect_url, remote_addr)
          start_response(
              '307 Temporary Redirect', [('location', redirect_url)])
          return ['<h1>307 Temporary Redirect</h1>\n']
    logging.error('No handler found for %s', path)
    start_response('404 Not Found', [])
    return ['<h1>404 Not Found</h1>\n']
Test adding to a group with a notification
dataset/ETHPy150Open GoogleCloudPlatform/python-compat-runtime/appengine-compat/exported_appengine_sdk/google/appengine/ext/vmruntime/meta_app.py/MetaWSGIApp.__call__--crossover with--dataset/ETHPy150Open ofa/connect/open_connect/groups/tests/test_tasks.py/TestAddUserToGroup.test_add_user_to_group_with_notification