Merge pull request #384 from cschleiden/copilot/fix-daa259f4-c639-4982-bda2-4ad946b6faf1

Fix executeEvent to handle EventType_WorkflowExecutionContinuedAsNew

Author: cschleiden

workflow/executor/executor.go

@@ -365,6 +365,9 @@ func (e *executor) executeEvent(event *history.Event) error {
 	case history.EventType_WorkflowExecutionFinished:
 	// Ignore
 
+	case history.EventType_WorkflowExecutionContinuedAsNew:
+	// Ignore
+
 	case history.EventType_WorkflowExecutionCanceled:
 		err = e.handleWorkflowCanceled()
 

workflow/executor/executor_test.go

@@ -707,6 +707,50 @@ func Test_Executor(t *testing.T) {
 				require.Equal(t, goRoutines, runtime.NumGoroutine())
 			},
 		},
+		{
+			name: "WorkflowExecutionContinuedAsNew event handled without error",
+			f: func(t *testing.T, r *registry.Registry, e *executor, i *core.WorkflowInstance, hp *testHistoryProvider) {
+				// Simple workflow that completes
+				wf := func(ctx sync.Context) error {
+					return nil
+				}
+
+				r.RegisterWorkflow(wf)
+
+				// Create a task with WorkflowExecutionContinuedAsNew event
+				result, _ := converter.DefaultConverter.To(42)
+				task := &backend.WorkflowTask{
+					ID:               "taskID",
+					WorkflowInstance: core.NewWorkflowInstance("instanceID", "executionID"),
+					Metadata:         &metadata.WorkflowMetadata{},
+					NewEvents: []*history.Event{
+						history.NewHistoryEvent(
+							1,
+							time.Now(),
+							history.EventType_WorkflowExecutionStarted,
+							&history.ExecutionStartedAttributes{
+								Name:   fn.Name(wf),
+								Inputs: []payload.Payload{},
+							},
+						),
+						history.NewHistoryEvent(
+							2,
+							time.Now(),
+							history.EventType_WorkflowExecutionContinuedAsNew,
+							&history.ExecutionContinuedAsNewAttributes{
+								Result:               result,
+								ContinuedExecutionID: "continued-execution-id",
+							},
+						),
+					},
+				}
+
+				// Execute the task - should not return an error
+				_, err := e.ExecuteTask(context.Background(), task)
+				require.NoError(t, err)
+				require.Nil(t, e.workflow.err)
+			},
+		},
 	}
 
 	for _, tt := range tests {