542
numTasks int,
543
newTaskFn func(definition.WorkflowKey, int64, time.Time) tasks.Task,
545
>
currentTaskID := int64(1)
546
>
now := time.Now().UTC()
547
>
randomTasks := make([]tasks.Task, 0, numTasks)
548
>
for i := 0; i != numTasks; i++ {
549
>
now = now.Truncate(common.ScheduledTaskMinPrecision)
550
>
randomTasks = append(randomTasks, newTaskFn(s.WorkflowKey, currentTaskID, now))
551
>
currentTaskID += rand.Int63n(100) + 1
552
>
now = now.Add(time.Duration(rand.Int63n(1000_000_000)) + time.Millisecond)
553
>
}
554
556
>
ShardID: s.ShardID,
557
>
RangeID: s.RangeID,
558
>
NamespaceID: s.WorkflowKey.NamespaceID,
559
>
WorkflowID: s.WorkflowKey.WorkflowID,
560
>
ArchetypeID: chasm.WorkflowArchetypeID,
561
>
Tasks: map[tasks.Category][]tasks.Task{
562
>
category: randomTasks,
563
>
},
564
>
})
565
>
s.NoError(err)
566
>
567
>
return randomTasks
568
}
569