Rest API for retry-history

src/rest-server/src/controllers/v2/job.js

@@ -146,7 +146,10 @@ const list = asyncHandler(async (req, res) => {
 });
 
 const get = asyncHandler(async (req, res) => {
-  const data = await job.get(req.params.frameworkName);
+  const data = await job.get(
+    req.params.frameworkName,
+    Number(req.params.jobAttemptId),
+  );
   res.json(data);
 });
 

src/rest-server/src/controllers/v2/task.js

@@ -0,0 +1,35 @@
+// Copyright (c) Microsoft Corporation
+// All rights reserved.
+//
+// MIT License
+//
+// Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated
+// documentation files (the "Software"), to deal in the Software without restriction, including without limitation
+// the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and
+// to permit persons to whom the Software is furnished to do so, subject to the following conditions:
+// The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.
+//
+// THE SOFTWARE IS PROVIDED *AS IS*, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING
+// BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+// NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
+// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+
+// module dependencies
+const asyncHandler = require('@pai/middlewares/v2/asyncHandler');
+const task = require('@pai/models/v2/task');
+
+const get = asyncHandler(async (req, res) => {
+  const result = await task.get(
+    req.params.frameworkName,
+    Number(req.params.jobAttemptId),
+    req.params.taskRoleName,
+    Number(req.params.taskIndex),
+  );
+  res.status(result.status).json(result.data);
+});
+
+// module exports
+module.exports = {
+  get,
+};

src/rest-server/src/models/v2/job-attempt.js

@@ -16,27 +16,11 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 
 // module dependencies
-const crypto = require('crypto');
-
 const { convertToJobAttempt } = require('@pai/utils/frameworkConverter');
 const launcherConfig = require('@pai/config/launcher');
 const logger = require('@pai/config/logger');
 const databaseModel = require('@pai/utils/dbUtils');
-
-const convertName = (name) => {
-  // convert framework name to fit framework controller spec
-  return name.toLowerCase().replace(/[^a-z0-9]/g, '');
-};
-
-const encodeName = (name) => {
-  if (name.startsWith('unknown') || !name.includes('~')) {
-    // framework is not generated by PAI
-    return convertName(name.replace(/^unknown/g, ''));
-  } else {
-    // md5 hash
-    return crypto.createHash('md5').update(name).digest('hex');
-  }
-};
+const encodeName = require('@pai/utils/name').encodeName;
 
 if (launcherConfig.enabledJobHistory) {
   const healthCheck = async () => {