Saas 6291 - added logs to tasks execution (#132)

Author: roi-codefresh

jobs/TaskPullerJob/tasks/CreatePod.task.js

@@ -1,14 +1,15 @@
 const Joi = require('joi');
 const Base = require('../../BaseJob');
 const { TASK_PRIORITY } = require('../../../constants');
+const _ = require('lodash');
 
 const ERROR_MESSAGES = {
 	FAILED_TO_EXECUTE_TASK: 'Failed to run task CreatePod',
 };
 
 class CreatePodTask extends Base {
 	async run(task) {
-		this.logger.info('Running CreatePod task');
+		this.logger.info(`Running CreatePod task - creating pod: ${_.get(task, 'spec.metadata.name')} in namespace: ${_.get(task, 'spec.metadata.namespace')}`);
 		try {
 			const pod = await this.kubernetesAPI.createPod(this.logger, task.spec);
 			return pod;

jobs/TaskPullerJob/tasks/CreatePvc.task.js

@@ -1,14 +1,15 @@
 const Joi = require('joi');
 const Base = require('../../BaseJob');
 const { TASK_PRIORITY } = require('../../../constants');
+const _ = require('lodash');
 
 const ERROR_MESSAGES = {
 	FAILED_TO_EXECUTE_TASK: 'Failed to run task CreatePvc',
 };
 
 class CreatePvcTask extends Base {
 	async run(task) {
-		this.logger.info('Running CreatePvc task');
+		this.logger.info(`Running CreatePvc task - creating pvc: ${_.get(task, 'spec.metadata.name')} in namespace: ${_.get(task, 'spec.metadata.namespace')}`);
 		try {
 			const pvc = await this.kubernetesAPI.createPvc(this.logger, task.spec);
 			return pvc;

jobs/TaskPullerJob/tasks/DeletePod.task.js

@@ -9,7 +9,7 @@ const ERROR_MESSAGES = {
 
 class DeletePodTask extends Base {
 	async run(task) {
-		this.logger.info('Running DeletePod task');
+		this.logger.info(`Running DeletePod task - deleting pod: ${_.get(task, 'spec.name')} from namespace: ${_.get(task, 'spec.namespace')}`);
 		try {
 			await this.kubernetesAPI.deletePod(this.logger, task.spec.namespace, task.spec.name);
 		} catch (err) {

jobs/TaskPullerJob/tasks/DeletePvc.task.js

@@ -9,7 +9,7 @@ const ERROR_MESSAGES = {
 
 class DeletePvcTask extends Base {
 	async run(task) {
-		this.logger.info('Running DeletePvc task');
+		this.logger.info(`Running DeletePvc task - deleting pvc: ${_.get(task, 'spec.name')} from namespace: ${_.get(task, 'spec.namespace')}`);
 		try {
 			await this.kubernetesAPI.deletePvc(this.logger, task.spec.namespace, task.spec.name);
 		} catch (err) {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "venona",
-  "version": "0.32.0",
+  "version": "0.32.1",
   "description": "Codefresh agent to run on Codefresh's runtime environment and execute pipeline",
   "main": "index.js",
   "scripts": {

venonactl/VERSION

@@ -1 +1 @@
-0.32.0
+0.32.1