| # Copyright (c) 2015 The Chromium Authors. All rights reserved. |
| # Use of this source code is governed by a BSD-style license that can be |
| # found in the LICENSE file. |
| import json |
| import webapp2 |
| |
| from google.appengine.api import taskqueue |
| from perf_insights.endpoints.cloud_mapper import job_info |
| |
| |
| class CancelPage(webapp2.RequestHandler): |
| |
| def get(self): |
| self.response.headers['Content-Type'] = 'text/plain' |
| |
| jobid = self.request.get('jobid') |
| job = job_info.JobInfo.get_by_id(jobid) |
| if not job: |
| response = {'success': False} |
| self.response.out.write(json.dumps(response)) |
| return |
| |
| taskqueue.Queue('mapper-queue').delete_tasks_by_name(job.running_tasks) |
| job.status = 'CANCELLED' |
| job.put() |
| |
| response = {'success': True} |
| self.response.out.write(json.dumps(response)) |
| |
| app = webapp2.WSGIApplication([('/cloud_mapper/cancel', CancelPage)]) |
