359
}
360
362
>
lastWriteVersion := rand.Int63()
363
>
_, newSnapshot, newEvents := s.CreateWorkflow(
364
>
lastWriteVersion,
365
>
enumsspb.WORKFLOW_EXECUTION_STATE_COMPLETED,
366
>
enumspb.WORKFLOW_EXECUTION_STATUS_COMPLETED,
367
>
rand.Int63(),
368
>
)
369
>
370
>
_, err := s.ExecutionManager.CreateWorkflowExecution(s.Ctx, &p.CreateWorkflowExecutionRequest{
371
>
ShardID: s.ShardID,
372
>
RangeID: s.RangeID,
373
>
Mode: p.CreateWorkflowModeUpdateCurrent,
374
>
375
>
PreviousRunID: newSnapshot.ExecutionState.RunId,
376
>
PreviousLastWriteVersion: lastWriteVersion,
377
>
378
>
ArchetypeID: chasm.WorkflowArchetypeID,
379
>
380
>
NewWorkflowSnapshot: *newSnapshot,
381
>
NewWorkflowEvents: newEvents,
382
>
})
383
>
s.IsType(&p.WorkflowConditionFailedError{}, err)
384
>
}
385
386
func (s *ExecutionMutableStateSuite) TestCreate_ClosedWorkflow_BrandNew() {