feat: add a log in the execution when the worker cannot send a messag…

…e to the queue
kestra-io · Sep 4, 2023 · 8da3eb8 · 8da3eb8
1 parent f7c2cda
commit 8da3eb8
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/core/src/main/java/io/kestra/core/runners/Worker.java b/core/src/main/java/io/kestra/core/runners/Worker.java
@@ -377,6 +377,11 @@ private WorkerTaskResult run(WorkerTask workerTask, Boolean cleanUp) throws Queu
                     .withState(State.Type.FAILED)
                 );
             WorkerTaskResult workerTaskResult = new WorkerTaskResult(finalWorkerTask, dynamicWorkerResults);
+            RunContext runContext = workerTask
+                .getRunContext()
+                .forWorker(this.applicationContext, workerTask);
+
+            runContext.logger().error("Exception while trying to emit the worker task result to the queue", e);
             this.workerTaskResultQueue.emit(workerTaskResult);
             return workerTaskResult;
         } finally {