UpdateWorkflowExecutionDTO updateWorkflowExecutionDTO = new UpdateWorkflowExecutionDTO() WorkflowExecutionStatus previousStatus = workflowExecution.status updateWorkflowExecutionDTO.updatedExecution = updateWorkflowExecutionV2(workflowExecution, updateWorkflowExecutionView) updateWorkflowExecutionDTO.isRateLimitedProcessingAllowed = previousStatus == RUNNING && updateWorkflowExecutionView.status == ACTION_NEEDED updateWorkflowExecutionDTO

java

package com.amazonaws.services.simpleworkflow.flow.interceptors;

import com.amazonaws.services.simpleworkflow.flow.DataConverter;
import com.amazonaws.services.simpleworkflow.flow.WorkflowClock;
import com.amazonaws.services.simpleworkflow.flow.WorkflowContext;
import com.amazonaws.services.simpleworkflow.flow.WorkflowExecution;
import com.amazonaws.services.simpleworkflow.flow.common.FlowConstants;
import com.amazonaws.services.simpleworkflow.flow.generic.ActivityExecutionContext;
import com.amazonaws.services.simpleworkflow.flow.generic.ActivityImplementation;
import com.amazonaws.services.simpleworkflow.flow.generic.ActivityImplementationFactory;
import com.amazonaws.services.simpleworkflow.flow.generic.ActivityImplementationOptions;
import com.amazonaws.services.simpleworkflow.flow.generic.ActivityImplementationOptions.ScheduleActivityTaskFailedCause;
import com.amazonaws.services.simple