diff --git a/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/TaskScheduleThread.java b/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/TaskScheduleThread.java
index 591712ba7d..89226bf8b5 100644
--- a/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/TaskScheduleThread.java
+++ b/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/TaskScheduleThread.java
@@ -182,7 +182,7 @@ public class TaskScheduleThread implements Callable<Boolean> {
                 );
                 status = ExecutionStatus.FAILURE;
             }else{
-                taskProps.setTenantCode(taskInstance.getProcessInstance().getTenantCode());
+                taskProps.setTenantCode(tenant.getTenantCode());
                 String queue = processDao.queryQueueByProcessInstanceId(processInstance.getId());
                 // set queue
                 if (StringUtils.isEmpty(queue)){