342
return err
343
}
345
>
if err != nil {
346
return err
347
}
348
350
>
if err != nil {
351
return err
352
}
353
354
>
retentionJitterDuration := backoff.FullJitter(r.config.RetentionTimerJitterDuration())
task_generator.go
355
>
deleteTime := closeTime.Add(retention).Add(retentionJitterDuration)
356
>
r.mutableState.AddTasks(&tasks.DeleteHistoryEventTask{
357
>
// TaskID is set by shard
358
>
WorkflowKey: r.mutableState.GetWorkflowKey(),
359
>
VisibilityTimestamp: deleteTime,
360
>
Version: closeVersion,
361
>
BranchToken: branchToken,
362
>
ArchetypeID: r.mutableState.ChasmTree().ArchetypeID(),
363
>
})
364
>
return nil
365
}
366