From 83cb2e8e979cc8431bb8a405a96829564bdbca6b Mon Sep 17 00:00:00 2001
From: Daniel Henrique Michalichyn <daniel.henrique@st-one.io>
Date: Mon, 24 May 2021 11:20:02 -0300
Subject: [PATCH 1/3] remove result output in succeded tasks

---
 src/app/worker.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/app/worker.ts b/src/app/worker.ts
index 1017c2b..587f3d9 100644
--- a/src/app/worker.ts
+++ b/src/app/worker.ts
@@ -147,7 +147,7 @@ export default class Worker extends Base {
         const diff = process.hrtime(timeStart);
         console.info(
           `celery.node Task ${taskName}[${taskId}] succeeded in ${diff[0] +
-            diff[1] / 1e9}s: ${result}`
+            diff[1] / 1e9}s.`
         );
         this.backend.storeResult(taskId, result, "SUCCESS");
         this.activeTasks.delete(taskPromise);

From 81fed2bb9398f543a73f8c4345808e099c7c6cae Mon Sep 17 00:00:00 2001
From: Daniel Henrique Michalichyn <daniel.henrique@st-one.io>
Date: Mon, 24 May 2021 15:42:49 -0300
Subject: [PATCH 2/3] Implementing a SELF variable for tasks information

---
 src/app/worker.ts | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/app/worker.ts b/src/app/worker.ts
index 587f3d9..489cc03 100644
--- a/src/app/worker.ts
+++ b/src/app/worker.ts
@@ -130,6 +130,7 @@ export default class Worker extends Base {
       // request
       const [args, kwargs /*, embed */] = body;
       const taskId = headers["id"];
+      const self = headers;
 
       const handler = this.handlers[taskName];
       if (!handler) {
@@ -143,7 +144,7 @@ export default class Worker extends Base {
       );
 
       const timeStart = process.hrtime();
-      const taskPromise = handler(...args, kwargs).then(result => {
+      const taskPromise = handler(...args, kwargs, self).then(result => {
         const diff = process.hrtime(timeStart);
         console.info(
           `celery.node Task ${taskName}[${taskId}] succeeded in ${diff[0] +

From 4293c2dfdc6a473cb01d9c5f9e56cb4cbee8b08c Mon Sep 17 00:00:00 2001
From: Daniel Henrique Michalichyn <daniel.henrique@st-one.io>
Date: Mon, 24 May 2021 15:50:08 -0300
Subject: [PATCH 3/3] added back the result output, in order to not mix
 branches modifications.

---
 src/app/worker.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/app/worker.ts b/src/app/worker.ts
index 489cc03..dd380a7 100644
--- a/src/app/worker.ts
+++ b/src/app/worker.ts
@@ -148,7 +148,7 @@ export default class Worker extends Base {
         const diff = process.hrtime(timeStart);
         console.info(
           `celery.node Task ${taskName}[${taskId}] succeeded in ${diff[0] +
-            diff[1] / 1e9}s.`
+            diff[1] / 1e9}s: ${result}`
         );
         this.backend.storeResult(taskId, result, "SUCCESS");
         this.activeTasks.delete(taskPromise);