Skip to content

Commit

Permalink
removed comments
Browse files Browse the repository at this point in the history
  • Loading branch information
kafkasl committed Apr 22, 2022
1 parent 049c0df commit a47845e
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 12 deletions.
9 changes: 0 additions & 9 deletions src/api/route-services/pipeline-response.js
Original file line number Diff line number Diff line change
Expand Up @@ -118,9 +118,7 @@ class PipelineService {
}

static async qcResponse(io, message) {
console.log('starting qc response', message);
AWSXRay.getSegment().addMetadata('message', message);
console.log('validating request');
await validateRequest(message, 'PipelineResponse.v1.yaml');

await pipelineHook.run(message);
Expand All @@ -130,20 +128,13 @@ class PipelineService {

let output = null;
// if there aren't errors proceed with the updates
console.log('and the rest is silence');
if (!error && 'output' in message) {
const { input: { sampleUuid, taskName } } = message;

console.log('getS3Output');
output = await this.getS3Output(message);
console.log('updatePlotData');
await this.updatePlotData(taskName, experimentId, output);
console.log('updateProcessingConfig');
await this.updateProcessingConfig(taskName, experimentId, output, sampleUuid);
}

console.log('and the rest is not silence');

// we want to send the update to the subscribed both in successful and error case
await this.sendUpdateToSubscribed(experimentId, message, output, error, io);
}
Expand Down
3 changes: 0 additions & 3 deletions src/utils/hooks/send-notification.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@
// const jwt = require('jsonwebtoken');
const getLogger = require('../getLogger');
const { authenticationMiddlewareSocketIO } = require('../authMiddlewares');
const getPipelineStatus = require('../../api/general-services/pipeline-status');
Expand All @@ -18,9 +17,7 @@ const sendNotification = async (message) => {
return;
}

logger.log('lcs verifying token ignoring expiration');
const user = await authenticationMiddlewareSocketIO(authJWT, true);
logger.log('lcs user', user);

const { experimentId } = message;
const statusRes = await getPipelineStatus(experimentId, process);
Expand Down

0 comments on commit a47845e

Please sign in to comment.