94
we *commonpb.WorkflowExecution,
95
ms historyi.MutableState,
97
>
taskGenerator := workflow.GetTaskGeneratorProvider().NewTaskGenerator(shardContext, ms)
98
>
99
>
// We can make this task immediately because the task itself will keep rescheduling itself until the
100
>
// execution is closed before actually deleting it.
101
>
deleteTask, err := taskGenerator.GenerateDeleteExecutionTask()
102
>
if err != nil {
103
return err
104
}
105
107
>
ShardID: shardContext.GetShardID(),
108
>
NamespaceID: nsID.String(),
109
>
WorkflowID: we.GetWorkflowId(),
110
>
ArchetypeID: ms.ChasmTree().ArchetypeID(),
111
>
Tasks: map[tasks.Category][]tasks.Task{
112
>
tasks.CategoryTransfer: {deleteTask},
113
>
},
114
>
})
115
}
116