(ctx context.Context)
| 65 | } |
| 66 | |
| 67 | func (tqs *TaskQueueSet) StartMain(ctx context.Context) { |
| 68 | tqs.GetByName(tqs.MainName).Start(ctx) |
| 69 | } |
| 70 | |
| 71 | func (tqs *TaskQueueSet) Start(ctx context.Context) { |
| 72 | tqs.IterateSnapshot(ctx, func(ctx context.Context, queue *TaskQueue) { |