(r"/jobs/([\w]{8}-[\w]{4}-[\w]{4}-[\w]{4}-[\w]{12})/retry", jobs.RetryHandler),
(r"/api/v1/jobs/([\w]{8}-[\w]{4}-[\w]{4}-[\w]{4}-[\w]{12})",
jobs.APIv1ControlHandler),
- (r"/api/v1/jobs/([\w]{8}-[\w]{4}-[\w]{4}-[\w]{4}-[\w]{12})/finished",
- jobs.APIv1FinishedHandler),
+ (r"/api/v1/jobs/([\w]{8}-[\w]{4}-[\w]{4}-[\w]{4}-[\w]{12})", jobs.APIv1IndexHandler),
(r"/api/v1/jobs/([\w]{8}-[\w]{4}-[\w]{4}-[\w]{4}-[\w]{12})/log/stream",
jobs.APIv1LogStreamHandler),
await self.logstream.message(timestamp, level, message)
-class APIv1FinishedHandler(base.APIMixin, tornado.web.RequestHandler):
- @tornado.web.authenticated
+class APIv1IndexHandler(base.APIMixin, tornado.web.RequestHandler):
+ @base.negotiate
async def post(self, uuid):
job = self.backend.jobs.get_by_uuid(uuid)
if not job:
self.backend.run_task(self.backend.builds.launch, builds)
# Send something back to the builder
- self.finish({
- "status" : "ok",
- })
+ self.finish({})
class APIv1LogStreamHandler(base.BackendMixin, tornado.websocket.WebSocketHandler):