code: private ExecutionMessage createInProgressExecutionMessage(Execution nextStepExecution) {
          // Take care of worker group
          String groupName = nextStepExecution.getGroupName();
          if (groupName == null) {
              groupName = WorkerNode.DEFAULT_WORKER_GROUPS[0];
          }
  
          Long id = queueStateIdGeneratorService.generateStateId();
          // Stay in the same worker in the next step
          return new ExecutionMessage(id,
                  executionMessage.getWorkerId(),
                  groupName,
                  executionMessage.getMsgId(),
                  ExecStatus.IN_PROGRESS,
                  nextStepExecution,
                  converter.createPayload(nextStepExecution),
                  0).setWorkerKey(executionMessage.getWorkerKey());
      }
docs: Creates InProgress execution message for the next step, base on current execution message - used for short cut!