update

5 years ago · 46bf965f81
1 changed files with 4 additions and 1 deletions
--- a/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java
+++ b/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java
@ -211,9 +211,12 @@ public class FetchTaskThread implements Runnable{
                            // set task execute path
                            taskInstance.setExecutePath(execLocalPath);

+                            Tenant tenant = processDao.getTenantForProcess(processInstance.getTenantId(),
+                                    processDefine.getUserId());
+
                            // check and create Linux users
                            FileUtils.createWorkDirAndUserIfAbsent(execLocalPath,
-                                    processInstance.getTenantCode(), logger);
+                                    tenant.getTenantCode(), logger);

                            logger.info("task : {} ready to submit to task scheduler thread",taskId);
                            // submit task