This is an automated email from the ASF dual-hosted git repository.

kerwin pushed a commit to branch 3.1.2-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/3.1.2-prepare by this push:
     new 3afc6e2480 cherry-pick [Bug-12954] [Schedule] Fix that workflow-level 
configuration information does not take effect when timing triggers execution
3afc6e2480 is described below

commit 3afc6e24802d01c11dc83ab538ce96f2db055eb2
Author: Kerwin <[email protected]>
AuthorDate: Tue Nov 22 15:35:29 2022 +0800

    cherry-pick [Bug-12954] [Schedule] Fix that workflow-level configuration 
information does not take effect when timing triggers execution
---
 .../apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java
 
b/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java
index 7b3eec4049..91728b6907 100644
--- 
a/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java
+++ 
b/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java
@@ -89,6 +89,7 @@ public class ProcessScheduleTask extends QuartzJobBean {
         command.setWarningGroupId(schedule.getWarningGroupId());
         String workerGroup = StringUtils.isEmpty(schedule.getWorkerGroup()) ? 
Constants.DEFAULT_WORKER_GROUP : schedule.getWorkerGroup();
         command.setWorkerGroup(workerGroup);
+        command.setEnvironmentCode(schedule.getEnvironmentCode());
         command.setWarningType(schedule.getWarningType());
         
command.setProcessInstancePriority(schedule.getProcessInstancePriority());
         command.setProcessDefinitionVersion(processDefinition.getVersion());

Reply via email to