retry signal & continue as new

temporalio · Apr 12, 2022 · 17a8b12 · 17a8b12
1 parent a274580
commit 17a8b12
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/service/history/historyEngine.go b/service/history/historyEngine.go
@@ -1953,6 +1953,7 @@ func (e *historyEngineImpl) SignalWorkflowExecution(
 		WorkflowId: request.WorkflowExecution.WorkflowId,
 		RunId:      request.WorkflowExecution.RunId,
 	}
+	currentWorkflow := execution.GetRunId() == ""
 
 	return e.updateWorkflow(
 		ctx,
@@ -1968,6 +1969,10 @@ func (e *historyEngineImpl) SignalWorkflowExecution(
 			}
 
 			if !mutableState.IsWorkflowExecutionRunning() {
+				_, status := mutableState.GetWorkflowStateStatus()
+				if status == enumspb.WORKFLOW_EXECUTION_STATUS_CONTINUED_AS_NEW && currentWorkflow {
+					return nil, serviceerror.NewUnavailable("try again")
+				}
 				return nil, consts.ErrWorkflowCompleted
 			}