2259
}
2260
2262
>
branchToken := RandomBranchToken(s.NamespaceID, s.WorkflowID, s.RunID, s.HistoryBranchUtil)
2263
>
newSnapshot, newEvents := RandomSnapshot(
2264
>
s.T(),
2265
>
s.NamespaceID,
2266
>
s.WorkflowID,
2267
>
s.RunID,
2268
>
common.FirstEventID,
2269
>
rand.Int63(),
2270
>
enumsspb.WORKFLOW_EXECUTION_STATE_ZOMBIE,
2271
>
enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING,
2272
>
rand.Int63(),
2273
>
branchToken,
2274
>
)
2275
>
2276
>
_, err := s.ExecutionManager.CreateWorkflowExecution(s.Ctx, &p.CreateWorkflowExecutionRequest{
2277
>
ShardID: s.ShardID,
2278
>
RangeID: s.RangeID,
2279
>
Mode: p.CreateWorkflowModeBypassCurrent,
2280
>
2281
>
PreviousRunID: "",
2282
>
PreviousLastWriteVersion: 0,
2283
>
2284
>
ArchetypeID: chasm.WorkflowArchetypeID,
2285
>
2286
>
NewWorkflowSnapshot: *newSnapshot,
2287
>
NewWorkflowEvents: newEvents,
2288
>
})
2289
>
s.NoError(err)
2290
>
2291
>
err = s.ExecutionManager.DeleteCurrentWorkflowExecution(s.Ctx, &p.DeleteCurrentWorkflowExecutionRequest{
2292
>
ShardID: s.ShardID,
2293
>
NamespaceID: s.NamespaceID,
2294
>
WorkflowID: s.WorkflowID,
2295
>
RunID: s.RunID,
2296
>
ArchetypeID: chasm.WorkflowArchetypeID,
2297
>
})
2298
>
s.NoError(err)
2299
>
2300
>
_, err = s.ExecutionManager.GetCurrentExecution(s.Ctx, &p.GetCurrentExecutionRequest{
2301
>
ShardID: s.ShardID,
2302
>
NamespaceID: s.NamespaceID,
2303
>
WorkflowID: s.WorkflowID,
2304
>
ArchetypeID: chasm.WorkflowArchetypeID,
2305
>
})
2306
>
s.IsType(&serviceerror.NotFound{}, err)
2307
>
s.EqualError(err, "workflow not found for ID: "+s.WorkflowID)
2308
>
2309
>
s.AssertMSEqualWithDB(chasm.WorkflowArchetypeID, newSnapshot)
2310
>
s.AssertHEEqualWithDB(branchToken, newEvents)
2311
>
}
2312
2313
func (s *ExecutionMutableStateSuite) TestDelete_Exists() {