Merge pull request #161 from kube-HPC/job-invoker

job invoker e2e

Author: RonShvarz

package-lock.json

@@ -24,6 +24,7 @@
     "@hkube/etcd": "^5.1.10",
     "@hkube/kubernetes-client": "^1.0.27",
     "@hkube/logger": "^1.0.30",
+    "@hkube/consts": "^1.0.59",
     "autocannon": "^7.4.0",
     "axios": "^0.21.1",
     "chai": "^4.1.2",

package.json

@@ -4,6 +4,7 @@ const chaiHttp = require("chai-http");
 const path = require("path");
 const delay = require("delay");
 var diff = require("deep-diff").diff;
+const { executeActions } = require('@hkube/consts');
 const config = require(path.join(process.cwd(), 'config/config'));
 
 
@@ -20,6 +21,7 @@ const {
   getWebSocketJobs,
   getWebSocketlogs,
   getDriverIdByJobId,
+  getJobById
 } = require("../utils/socketGet");
 const { getStatus } = require("../utils/results")
 
@@ -806,6 +808,12 @@ let dev_token;
       expect(pipelineStatus.body.status).to.be.equal("paused");
       await resumePipeline(jobId, dev_token);
       await getResult(jobId, 200, dev_token);
+      const jobBody = await getJobById(dev_token, jobId)
+      expect(jobBody.job).to.have.property("auditTrail");
+      expect(jobBody.job.auditTrail[jobBody.job.auditTrail.length -1].action).to.eql(executeActions.RUN);
+      expect(jobBody.job.auditTrail[jobBody.job.auditTrail.length -2].action).to.eql(executeActions.PAUSE);
+      expect(jobBody.job.auditTrail[jobBody.job.auditTrail.length -3].action).to.eql(executeActions.RESUME);
+      expect(jobBody.job.auditTrail[jobBody.job.auditTrail.length -3].timestamp).to.be.gt(jobBody.job.auditTrail[jobBody.job.auditTrail.length -1].timestamp)
     }).timeout(1000 * 60 * 5);
 
     it("pause resume pipeline multiple batch", async () => {

tests/pipeline_tests.js

@@ -116,6 +116,11 @@ const JOB_BY_ID_QUERY = gql`
           progress
         }
       }
+      auditTrail {
+        timestamp
+        user
+        action
+      }
       pipeline {
         name
         experimentName