mapper fix 1

Author: timl3136

internal/compatibility/proto/types.go

@@ -417,6 +417,7 @@ func WorkflowExecutionInfo(t *shared.WorkflowExecutionInfo) *apiv1.WorkflowExecu
 		AutoResetPoints:     ResetPoints(t.AutoResetPoints),
 		TaskList:            t.GetTaskList(),
 		IsCron:              t.GetIsCron(),
+		CronOverlapPolicy:   CronOverlapPolicy(t.CronOverlapPolicy),
 	}
 }
 

internal/compatibility/testdata/common.go

@@ -48,6 +48,7 @@ const (
 	HostName             = "HostName"
 	Identity             = "Identity"
 	CronSchedule         = "CronSchedule"
+	CronOverlapPolicy    = 0
 	Checksum             = "Checksum"
 	Reason               = "Reason"
 	Cause                = "Cause"

internal/compatibility/testdata/decision.go

@@ -106,6 +106,7 @@ var (
 		Memo:                         &Memo,
 		SearchAttributes:             &SearchAttributes,
 		JitterStart:                  Duration4,
+		CronOverlapPolicy:            apiv1.CronOverlapPolicy_CRON_OVERLAP_POLICY_SKIPPED,
 	}
 	FailWorkflowExecutionDecisionAttributes = apiv1.FailWorkflowExecutionDecisionAttributes{
 		Failure: &Failure,

internal/compatibility/thrift/types.go

@@ -421,20 +421,21 @@ func WorkflowExecutionInfo(t *apiv1.WorkflowExecutionInfo) *shared.WorkflowExecu
 		return nil
 	}
 	return &shared.WorkflowExecutionInfo{
-		Execution:        WorkflowExecution(t.WorkflowExecution),
-		Type:             WorkflowType(t.Type),
-		StartTime:        timeToUnixNano(t.StartTime),
-		CloseTime:        timeToUnixNano(t.CloseTime),
-		CloseStatus:      WorkflowExecutionCloseStatus(t.CloseStatus),
-		HistoryLength:    &t.HistoryLength,
-		ParentDomainId:   ParentDomainID(t.ParentExecutionInfo),
-		ParentExecution:  ParentWorkflowExecution(t.ParentExecutionInfo),
-		ExecutionTime:    timeToUnixNano(t.ExecutionTime),
-		Memo:             Memo(t.Memo),
-		SearchAttributes: SearchAttributes(t.SearchAttributes),
-		AutoResetPoints:  ResetPoints(t.AutoResetPoints),
-		TaskList:         &t.TaskList,
-		IsCron:           &t.IsCron,
+		Execution:         WorkflowExecution(t.WorkflowExecution),
+		Type:              WorkflowType(t.Type),
+		StartTime:         timeToUnixNano(t.StartTime),
+		CloseTime:         timeToUnixNano(t.CloseTime),
+		CloseStatus:       WorkflowExecutionCloseStatus(t.CloseStatus),
+		HistoryLength:     &t.HistoryLength,
+		ParentDomainId:    ParentDomainID(t.ParentExecutionInfo),
+		ParentExecution:   ParentWorkflowExecution(t.ParentExecutionInfo),
+		ExecutionTime:     timeToUnixNano(t.ExecutionTime),
+		Memo:              Memo(t.Memo),
+		SearchAttributes:  SearchAttributes(t.SearchAttributes),
+		AutoResetPoints:   ResetPoints(t.AutoResetPoints),
+		TaskList:          &t.TaskList,
+		IsCron:            &t.IsCron,
+		CronOverlapPolicy: CronOverlapPolicy(t.CronOverlapPolicy),
 	}
 }
 

internal/internal_workflow.go

@@ -183,6 +183,7 @@ type (
 		dataConverter                       DataConverter
 		retryPolicy                         *shared.RetryPolicy
 		cronSchedule                        string
+		cronOverlapPolicy                   shared.CronOverlapPolicy
 		contextPropagators                  []ContextPropagator
 		memo                                map[string]interface{}
 		searchAttributes                    map[string]interface{}

internal/internal_workflow_testsuite.go

@@ -191,9 +191,10 @@ type (
 		workerStopChannel  chan struct{}
 		sessionEnvironment *testSessionEnvironmentImpl
 
-		cronSchedule   string
-		cronIterations int
-		workflowInput  []byte
+		cronSchedule      string
+		cronIterations    int
+		workflowInput     []byte
+		cronOverlapPolicy shared.CronOverlapPolicy
 	}
 
 	testSessionEnvironmentImpl struct {
@@ -391,6 +392,7 @@ func (env *testWorkflowEnvironmentImpl) newTestWorkflowEnvironmentForChild(param
 	childEnv.workflowInfo.ParentWorkflowDomain = &env.workflowInfo.Domain
 	childEnv.workflowInfo.ParentWorkflowExecution = &env.workflowInfo.WorkflowExecution
 	childEnv.executionTimeout = time.Duration(*params.executionStartToCloseTimeoutSeconds) * time.Second
+	childEnv.cronOverlapPolicy = params.cronOverlapPolicy
 	if workflowHandler, ok := env.runningWorkflows[params.workflowID]; ok {
 		// duplicate workflow ID
 		if !workflowHandler.handled {