fix(core): handle worker thread context globally

close #819
kestra-io · Jan 19, 2023 · f76c2d3 · f76c2d3
1 parent 4bc6dda
commit f76c2d3
Showing 1 changed file with 2 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
@@ -475,6 +475,8 @@ public WorkerThread(Logger logger, WorkerTask workerTask, RunnableTask<?> task,
 
         @Override
         public void run() {
+            Thread.currentThread().setContextClassLoader(this.task.getClass().getClassLoader());
+
             try {
                 // timeout
                 if (workerTask.getTask().getTimeout() != null) {