2311
}
2312
2314
>
branchToken := RandomBranchToken(s.NamespaceID, s.WorkflowID, s.RunID, s.HistoryBranchUtil)
2315
>
newSnapshot, newEvents := RandomSnapshot(
2316
>
s.T(),
2317
>
s.NamespaceID,
2318
>
s.WorkflowID,
2319
>
s.RunID,
2320
>
rand.Int63(),
2321
>
rand.Int63(),
2322
>
enumsspb.WORKFLOW_EXECUTION_STATE_ZOMBIE,
2323
>
enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING,
2324
>
rand.Int63(),
2325
>
branchToken,
2326
>
)
2327
>
2328
>
_, err := s.ExecutionManager.CreateWorkflowExecution(s.Ctx, &p.CreateWorkflowExecutionRequest{
2329
>
ShardID: s.ShardID,
2330
>
RangeID: s.RangeID,
2331
>
Mode: p.CreateWorkflowModeBypassCurrent,
2332
>
2333
>
PreviousRunID: "",
2334
>
PreviousLastWriteVersion: 0,
2335
>
2336
>
ArchetypeID: chasm.WorkflowArchetypeID,
2337
>
2338
>
NewWorkflowSnapshot: *newSnapshot,
2339
>
NewWorkflowEvents: newEvents,
2340
>
})
2341
>
s.NoError(err)
2342
>
2343
>
err = s.ExecutionManager.DeleteWorkflowExecution(s.Ctx, &p.DeleteWorkflowExecutionRequest{
2344
>
ShardID: s.ShardID,
2345
>
NamespaceID: s.NamespaceID,
2346
>
WorkflowID: s.WorkflowID,
2347
>
RunID: s.RunID,
2348
>
ArchetypeID: chasm.WorkflowArchetypeID,
2349
>
})
2350
>
s.NoError(err)
2351
>
2352
>
s.AssertMissingFromDB(s.NamespaceID, s.WorkflowID, s.RunID, chasm.WorkflowArchetypeID)
2353
>
}
2354
2355
func (s *ExecutionMutableStateSuite) TestDelete_NotExists() {